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
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
