void initializeState ( final ListState < byte [ ] > bucketStates , final ListState < Long > partCounterState ) throws Exception { initializePartCounter ( partCounterState ) ; LOG . info ( "Subtask {} initializing its state (max part counter={})." , subtaskIndex , maxPartCounter ) ; initializeActiveBuckets ( bucketStates ) ; }
Initializes the state after recovery from a failure .