Hi Ken, LocalFlinkMiniCluster should run checkpoints just fine. It looks like it was attempting to even create one but could not finish. Maybe your program was not fully running yet? Can you tell us a little bit more about your set up and how you configured the LocalFlinkMiniCluster?
Nico On 23/02/18 21:42, Ken Krugler wrote: > Hi all, > > For testing checkpointing, is it possible to use LocalFlinkMiniCluster? > > Asking because I’m not seeing checkpoint calls being made to my custom > function (implements ListCheckpointed) when I’m running with > LocalFlinkMiniCluster. > > Though I do see entries like this logged: > > 18/02/23 12:40:50 INFO jobmanager.JobManager:246 - Using application-defined > state backend for checkpoint/savepoint metadata: MemoryStateBackend (data in > heap memory / checkpoints to JobManager). > 18/02/23 12:40:50 INFO checkpoint.CheckpointCoordinator:525 - Checkpoint > triggering task Source: Seed urls source (1/2) is not being executed at the > moment. Aborting checkpoint. > > But when I browse the Flink source, tests for checkpointing seem to be using > TestCluster, e.g. in ResumeCheckpointManuallyITCase > > Thanks, > > — Ken > > -------------------------------------------- > http://about.me/kkrugler > +1 530-210-6378 >
signature.asc
Description: OpenPGP digital signature
