Re: Approach to test custom Source/Sink

Hi Bin, We could try the following method to cover the source/sink test. Unit test: To verify whether the behavior of each method in custom source or sink is expected. You could mock interactions with external storage (database, IO, etc.) in this part. Integration test: To test whether the source/s

Re: Approach to test custom Source/Sink

Hi! Currently there is no general principle for testing sources and sinks. However you might want to check out the unit tests and IT cases for Flink connectors. For example flink-connector-jdbc module has a lot of tests for the JDBC source and sink. Follow the ideas in these tests should be enough

Approach to test custom Source/Sink

Hi team, I'm currently implementing a custom source and sink, and I'm trying to find a way to test these implementations. The testing section in the of