The remaining piece for first cut is APEXCORE-306. We need to ensure that operators in the loop (strongly connected) move recovery checkpoint lockstep. Identifying the loop will be done with the existing logic in LogicalPlan. What I have so far is first cut changes to updateRecoveryCheckpoints, using the group of logical operators to compute the checkpoint dependencies:
https://github.com/tweise /incubator-apex-core/commit/fc672a6f46f1f6c76c552ecee0740b795129fc0c David, Gaurav, Pramod please have a look. We aim to complete this EOW for the release candidate. I'm working on identifying the checkpoint groups now, will have that ready later tonight. Thanks
