[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Test harness for validating proper checkpointing of custom SourceFunction

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.


— Ken

Ken Krugler
+1 530-210-6378
Custom big data solutions & training
Flink, Solr, Hadoop, Cascading & Cassandra