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.
Xinbin Huang <b...@apache.org> 于2021年8月10日周二 上午4:22写道： > 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 > <https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/datastream/testing/#unit-testing-stateful-or-timely-udfs--custom-operators> > in the official doc seems to only include testing for stateful/stateless > operators. Do you have any recommendations on how I should approach this? > > Thanks > Bin >
