Does anyone know how to use (or what to use instead of)

OneInputStreamOperatorTestHarness

with new

FileSink

instead of deprecated

StreamingFileSink

?

StreamingFileSink

implements

SinkFunction

and can be used as parameter for

OneInputStreamOperator

, but new

FileSink

isn’t suitable here.

Hey Oleg. Not sure what exactly you want to test and which way would be the most appropriate for you, but I think you can inspire in KafkaSink tests: https://github.com/apache/flink/tree/master/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink