Hi all, We’re using the (Keyed)(One|Two)InputStreamOperatorTestHarness classes to test checkpointing of some custom functions.
But in looking through the Flink source, I didn’t see anything comparable for testing a custom SourceFunction (which implements the ListCheckpointed interface). What’s the recommended approach for this? We can of course fire up the workflow with checkpointing, and add some additional logic that kills the job after a checkpoint has happened, etc. But it seems like there should be a better way. Thanks, — Ken -------------------------- Ken Krugler +1 530-210-6378 http://www.scaleunlimited.com Custom big data solutions & training Flink, Solr, Hadoop, Cascading & Cassandra
