|
Change Variable Type taskLocalStateStore : TaskLocalStateStoreImpl to taskLocalStateStore : OwnedTaskLocalStateStore in method public localStateStoreForSubtask(jobId JobID, allocationID AllocationID, jobVertexID JobVertexID, subtaskIndex int) : TaskLocalStateStore in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Change Variable Type taskStateManagers : Map<JobVertexSubtaskKey,TaskLocalStateStoreImpl> to taskStateManagers : Map<JobVertexSubtaskKey,OwnedTaskLocalStateStore> in method public localStateStoreForSubtask(jobId JobID, allocationID AllocationID, jobVertexID JobVertexID, subtaskIndex int) : TaskLocalStateStore in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Change Variable Type stateStore : TaskLocalStateStoreImpl to stateStore : OwnedTaskLocalStateStore in method private doRelease(toRelease Iterable<OwnedTaskLocalStateStore>) : void in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Change Variable Type toRelease : HashMap<AllocationID,Map<JobVertexSubtaskKey,TaskLocalStateStoreImpl>> to toRelease : HashMap<AllocationID,Map<JobVertexSubtaskKey,OwnedTaskLocalStateStore>> in method public shutdown() : void in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Change Variable Type cleanupLocalStores : Map<JobVertexSubtaskKey,TaskLocalStateStoreImpl> to cleanupLocalStores : Map<JobVertexSubtaskKey,OwnedTaskLocalStateStore> in method public releaseLocalStateForAllocationId(allocationID AllocationID) : void in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Change Variable Type entry : Map.Entry<AllocationID,Map<JobVertexSubtaskKey,TaskLocalStateStoreImpl>> to entry : Map.Entry<AllocationID,Map<JobVertexSubtaskKey,OwnedTaskLocalStateStore>> in method public shutdown() : void in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |