@ Override protected final void acknowledgeIDs ( long checkpointId , Set < UId > uniqueIds ) { LOG . debug ( "Acknowledging ids for checkpoint {}" , checkpointId ) ; Iterator < Tuple2 < Long , List < SessionId > > > iterator = sessionIdsPerSnapshot . iterator ( ) ; while ( iterator . hasNext ( ) ) { final Tuple2 < Long , List < SessionId > > next = iterator . next ( ) ; long id = next . f0 ; if ( id <= checkpointId ) { acknowledgeSessionIDs ( next . f1 ) ; // remove ids for this session iterator . remove ( ) ; } } }
Acknowledges the session ids .