|
Change Parameter Type taskStates : Collection<TaskState> to operatorStates : Collection<OperatorState> in method protected verifyCheckpointDiscarded(operatorStates Collection<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Parameter Type taskStates : Collection<TaskState> to operatorStates : Collection<OperatorState> in method protected verifyCheckpointRegistered(operatorStates Collection<OperatorState>, registry SharedStateRegistry) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Parameter Type taskState : TaskState to operatorState : OperatorState in method private checkParallelismPreconditions(operatorState OperatorState, executionJobVertex ExecutionJobVertex) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Parameter Type operatorStates : List<TaskState> to operatorStates : List<OperatorState> in method private reDistributePartitionableStates(operatorStates List<OperatorState>, newParallelism int, newManagedOperatorStates List<List<Collection<OperatorStateHandle>>>, newRawOperatorStates List<List<Collection<OperatorStateHandle>>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Parameter Type taskStates : Collection<TaskState> to operatorStates : Collection<OperatorState> in method private testCheckpointSerialization(checkpointId long, operatorStates Collection<OperatorState>, masterStates Collection<MasterState>) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2SerializerTest |
From |
To |
|
Change Parameter Type taskStates : Map<JobVertexID,TaskState> to operatorStates : Map<OperatorID,OperatorState> in method public CompletedCheckpoint(job JobID, checkpointID long, timestamp long, completionTimestamp long, operatorStates Map<OperatorID,OperatorState>, masterHookStates Collection<MasterState>, props CheckpointProperties, externalizedMetadata StreamStateHandle, externalPointer String) in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint |
From |
To |
|
Change Parameter Type taskGroupStates : Map<JobVertexID,TaskState> to operatorGroupState : Map<OperatorID,OperatorState> in method public TestCompletedCheckpoint(jobId JobID, checkpointId long, timestamp long, operatorGroupState Map<OperatorID,OperatorState>, props CheckpointProperties) in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest.TestCompletedCheckpoint |
From |
To |
|
Change Parameter Type taskState : TaskState to executionJobVertex : ExecutionJobVertex in method private assignAttemptState(executionJobVertex ExecutionJobVertex, operatorStates List<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Parameter Type operatorState : TaskState to operatorState : OperatorState in method public getManagedKeyedStateHandles(operatorState OperatorState, subtaskKeyGroupRange KeyGroupRange) : List<KeyedStateHandle> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Parameter Type operatorState : TaskState to operatorState : OperatorState in method public getRawKeyedStateHandles(operatorState OperatorState, subtaskKeyGroupRange KeyGroupRange) : List<KeyedStateHandle> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Parameter Type operatorState : TaskState to operatorState : OperatorState in method private reAssignSubKeyedStates(operatorState OperatorState, keyGroupPartitions List<KeyGroupRange>, subTaskIndex int, newParallelism int, oldParallelism int) : Tuple2<Collection<KeyedStateHandle>,Collection<KeyedStateHandle>> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Parameter Type taskStates : Collection<TaskState> to operatorStates : Collection<OperatorState> in method protected resetCheckpoint(operatorStates Collection<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Parameter Type state : TaskState to state : OperatorState in method package setTaskState(pending PendingCheckpoint, state OperatorState) : void in class org.apache.flink.runtime.checkpoint.PendingCheckpointTest |
From |
To |
|
Change Parameter Type operatorState : TaskState to operatorState : OperatorState in method private reAssignSubNonPartitionedStates(operatorState OperatorState, subTaskIndex int, newParallelism int, oldParallelism int, subNonPartitionableState List<StreamStateHandle>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Parameter Type operatorStates : List<TaskState> to operatorStates : List<OperatorState> in method private collectPartionableStates(operatorStates List<OperatorState>, managedOperatorStates List<List<OperatorStateHandle>>, rawOperatorStates List<List<OperatorStateHandle>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Move Method private reAssignSubPartitionableState(newMangedOperatorStates List<List<Collection<OperatorStateHandle>>>, newRawOperatorStates List<List<Collection<OperatorStateHandle>>>, subTaskIndex int, operatorIndex int, subManagedOperatorState List<Collection<OperatorStateHandle>>, subRawOperatorState List<Collection<OperatorStateHandle>>) : void from class org.apache.flink.runtime.checkpoint.StateAssignmentOperationV2 to private reAssignSubPartitionableState(newMangedOperatorStates List<List<Collection<OperatorStateHandle>>>, newRawOperatorStates List<List<Collection<OperatorStateHandle>>>, subTaskIndex int, operatorIndex int, subManagedOperatorState List<Collection<OperatorStateHandle>>, subRawOperatorState List<Collection<OperatorStateHandle>>) : void from class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Move Method private collectPartionableStates(operatorStates List<TaskState>, managedOperatorStates List<List<OperatorStateHandle>>, rawOperatorStates List<List<OperatorStateHandle>>) : void from class org.apache.flink.runtime.checkpoint.StateAssignmentOperationV2 to private collectPartionableStates(operatorStates List<OperatorState>, managedOperatorStates List<List<OperatorStateHandle>>, rawOperatorStates List<List<OperatorStateHandle>>) : void from class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Move Method private reAssignSubKeyedStates(operatorState TaskState, keyGroupPartitions List<KeyGroupRange>, subTaskIndex int, newParallelism int, oldParallelism int) : Tuple2<Collection<KeyedStateHandle>,Collection<KeyedStateHandle>> from class org.apache.flink.runtime.checkpoint.StateAssignmentOperationV2 to private reAssignSubKeyedStates(operatorState OperatorState, keyGroupPartitions List<KeyGroupRange>, subTaskIndex int, newParallelism int, oldParallelism int) : Tuple2<Collection<KeyedStateHandle>,Collection<KeyedStateHandle>> from class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Move Method public getRawKeyedStateHandles(operatorState TaskState, subtaskKeyGroupRange KeyGroupRange) : List<KeyedStateHandle> from class org.apache.flink.runtime.checkpoint.StateAssignmentOperationV2 to public getRawKeyedStateHandles(operatorState OperatorState, subtaskKeyGroupRange KeyGroupRange) : List<KeyedStateHandle> from class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Move Method private reDistributePartitionableStates(operatorStates List<TaskState>, newParallelism int, newManagedOperatorStates List<List<Collection<OperatorStateHandle>>>, newRawOperatorStates List<List<Collection<OperatorStateHandle>>>) : void from class org.apache.flink.runtime.checkpoint.StateAssignmentOperationV2 to private reDistributePartitionableStates(operatorStates List<OperatorState>, newParallelism int, newManagedOperatorStates List<List<Collection<OperatorStateHandle>>>, newRawOperatorStates List<List<Collection<OperatorStateHandle>>>) : void from class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Move Method private reAssignSubNonPartitionedStates(operatorState TaskState, subTaskIndex int, newParallelism int, oldParallelism int, subNonPartitionableState List<StreamStateHandle>) : void from class org.apache.flink.runtime.checkpoint.StateAssignmentOperationV2 to private reAssignSubNonPartitionedStates(operatorState OperatorState, subTaskIndex int, newParallelism int, oldParallelism int, subNonPartitionableState List<StreamStateHandle>) : void from class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Move Method private allElementsAreNull(nonPartitionableStates List<X>) : boolean from class org.apache.flink.runtime.checkpoint.StateAssignmentOperationV2 to private allElementsAreNull(nonPartitionableStates List<X>) : boolean from class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Move Method public getManagedKeyedStateHandles(operatorState TaskState, subtaskKeyGroupRange KeyGroupRange) : List<KeyedStateHandle> from class org.apache.flink.runtime.checkpoint.StateAssignmentOperationV2 to public getManagedKeyedStateHandles(operatorState OperatorState, subtaskKeyGroupRange KeyGroupRange) : List<KeyedStateHandle> from class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Rename Variable taskState : TaskState to operatorState : OperatorState in method public testAddCheckpointMoreThanMaxRetained() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Rename Variable taskStates : Map<JobVertexID,TaskState> to operatorStates : Map<OperatorID,OperatorState> in method public testCompletedCheckpointStatsCallbacks() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointTest |
From |
To |
|
Rename Variable taskState : TaskState to operatorState : OperatorState in method public testTriggerSavepointAndResumeWithFileBasedCheckpoints() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Rename Variable taskState : TaskState to operatorState : OperatorState in method public loadAndValidateSavepoint(jobId JobID, tasks Map<JobVertexID,ExecutionJobVertex>, savepointPath String, classLoader ClassLoader, allowNonRestoredState boolean) : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointLoader |
From |
To |
|
Rename Variable taskStates : Map<JobVertexID,TaskState> to operatorStates : HashMap<OperatorID,OperatorState> in method public loadAndValidateSavepoint(jobId JobID, tasks Map<JobVertexID,ExecutionJobVertex>, savepointPath String, classLoader ClassLoader, allowNonRestoredState boolean) : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointLoader |
From |
To |
|
Rename Variable taskState : TaskState to operatorState : OperatorState in method public getStateSize() : long in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint |
From |
To |
|
Rename Variable taskStates : Map<JobVertexID,TaskState> to operatorStates : Map<OperatorID,OperatorState> in method public testCleanUpOnShutdown() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointTest |
From |
To |
|
Rename Variable taskGroupStateEntry : Map.Entry<JobVertexID,TaskState> to task : Map.Entry<JobVertexID,ExecutionJobVertex> in method public assignStates() : boolean in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Rename Variable taskStates : Map<JobVertexID,TaskState> to operatorStates : Map<OperatorID,OperatorState> in method public restoreLatestCheckpointedState(tasks Map<JobVertexID,ExecutionJobVertex>, errorIfNoCheckpoint boolean, allowNonRestoredState boolean) : boolean in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Rename Variable taskState : TaskState to operatorState : OperatorState in method public acknowledgeTask(executionAttemptId ExecutionAttemptID, subtaskState SubtaskState, metrics CheckpointMetrics) : TaskAcknowledgeResult in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Rename Variable parallelKeyedStateStream : List<KeyedStateHandle> to oldRawOperatorStates : List<List<OperatorStateHandle>> in method private reDistributePartitionableStates(operatorStates List<OperatorState>, newParallelism int, newManagedOperatorStates List<List<Collection<OperatorStateHandle>>>, newRawOperatorStates List<List<Collection<OperatorStateHandle>>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Rename Variable tasks : Map<JobVertexID,ExecutionJobVertex> to operatorToJobVertexMapping : Map<OperatorID,ExecutionJobVertex> in method public loadAndValidateSavepoint(jobId JobID, tasks Map<JobVertexID,ExecutionJobVertex>, savepointPath String, classLoader ClassLoader, allowNonRestoredState boolean) : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointLoader |
From |
To |
|
Rename Variable parallelKeyedStatesBackend : List<KeyedStateHandle> to oldManagedOperatorStates : List<List<OperatorStateHandle>> in method private reDistributePartitionableStates(operatorStates List<OperatorState>, newParallelism int, newManagedOperatorStates List<List<Collection<OperatorStateHandle>>>, newRawOperatorStates List<List<Collection<OperatorStateHandle>>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Rename Variable subtaskKeyGroupIds : KeyGroupRange to operatorState : OperatorState in method private assignAttemptState(executionJobVertex ExecutionJobVertex, operatorStates List<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Rename Variable taskStates : Collection<TaskState> to operatorStates : Collection<OperatorState> in method public serialize(checkpointMetadata SavepointV2, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer |
From |
To |
|
Rename Variable taskStates : Collection<TaskState> to operatorStates : Collection<OperatorState> in method public testCheckpointWithOnlyMasterState() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2SerializerTest |
From |
To |
|
Rename Variable taskState : TaskState to operatorState : OperatorState in method protected verifyCheckpointDiscarded(operatorStates Collection<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Rename Variable taskStates : ArrayList<TaskState> to operatorStates : List<OperatorState> in method public deserialize(dis DataInputStream, cl ClassLoader) : SavepointV2 in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer |
From |
To |
|
Rename Variable taskStates : Map<JobVertexID,TaskState> to operatorStates : Map<OperatorID,OperatorState> in method public testCleanUpOnSubsume() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointTest |
From |
To |
|
Rename Variable taskState : TaskState to operatorState : OperatorState in method public dispose() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2 |
From |
To |
|
Rename Variable taskState : TaskState to operatorState : OperatorState in method protected resetCheckpoint(operatorStates Collection<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Rename Variable taskState : TaskState to operatorState : OperatorState in method public serialize(checkpointMetadata SavepointV2, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer |
From |
To |
|
Rename Variable jobVertexID : JobVertexID to operatorID : OperatorID in method public acknowledgeTask(executionAttemptId ExecutionAttemptID, subtaskState SubtaskState, metrics CheckpointMetrics) : TaskAcknowledgeResult in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Rename Variable expandedToLegacyIds : boolean to statelessTask : boolean in method public assignStates() : boolean in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Rename Variable newKeyedStatesBackend : List<KeyedStateHandle> to subRawKeyedState : Collection<KeyedStateHandle> in method private reAssignSubKeyedStates(operatorState OperatorState, keyGroupPartitions List<KeyGroupRange>, subTaskIndex int, newParallelism int, oldParallelism int) : Tuple2<Collection<KeyedStateHandle>,Collection<KeyedStateHandle>> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Rename Variable taskState : TaskState to operatorState : OperatorState in method protected verifyCheckpointRegistered(operatorStates Collection<OperatorState>, registry SharedStateRegistry) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Rename Variable taskStates : Collection<TaskState> to operatorStates : Collection<OperatorState> in method public testShutdownDiscardsCheckpoints() : void in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStoreTest |
From |
To |
|
Rename Variable newKeyedStateStream : List<KeyedStateHandle> to subManagedKeyedState : Collection<KeyedStateHandle> in method private reAssignSubKeyedStates(operatorState OperatorState, keyGroupPartitions List<KeyGroupRange>, subTaskIndex int, newParallelism int, oldParallelism int) : Tuple2<Collection<KeyedStateHandle>,Collection<KeyedStateHandle>> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type taskState : TaskState to operatorState : OperatorState in method public serialize(checkpointMetadata SavepointV2, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer |
From |
To |
|
Change Variable Type jobVertexID : JobVertexID to operatorID : OperatorID in method public acknowledgeTask(executionAttemptId ExecutionAttemptID, subtaskState SubtaskState, metrics CheckpointMetrics) : TaskAcknowledgeResult in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Change Variable Type subtaskStateMap : Map<Integer,SubtaskState> to subtaskStateMap : Map<Integer,OperatorSubtaskState> in method public serialize(checkpointMetadata SavepointV2, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer |
From |
To |
|
Change Variable Type taskStates : Map<JobVertexID,TaskState> to operatorStates : HashMap<OperatorID,OperatorState> in method public loadAndValidateSavepoint(jobId JobID, tasks Map<JobVertexID,ExecutionJobVertex>, savepointPath String, classLoader ClassLoader, allowNonRestoredState boolean) : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointLoader |
From |
To |
|
Change Variable Type taskStates : Collection<TaskState> to taskStates : Collection<OperatorState> in method public testSavepointV2() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Test |
From |
To |
|
Change Variable Type taskState : TaskState to operatorState : OperatorState in method public getStateSize() : long in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint |
From |
To |
|
Change Variable Type taskGroupStateEntry : Map.Entry<JobVertexID,TaskState> to task : Map.Entry<JobVertexID,ExecutionJobVertex> in method public assignStates() : boolean in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type state : TaskState to state : OperatorState in method public testAbortDiscardsState() : void in class org.apache.flink.runtime.checkpoint.PendingCheckpointTest |
From |
To |
|
Change Variable Type subtaskState : SubtaskState to subtaskState : OperatorSubtaskState in method public deserialize(dis DataInputStream, cl ClassLoader) : SavepointV2 in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer |
From |
To |
|
Change Variable Type state : TaskState to state : OperatorState in method public testCleanUpOnSubsume() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointTest |
From |
To |
|
Change Variable Type newKeyedStatesBackend : List<KeyedStateHandle> to subRawKeyedState : Collection<KeyedStateHandle> in method private reAssignSubKeyedStates(operatorState OperatorState, keyGroupPartitions List<KeyGroupRange>, subTaskIndex int, newParallelism int, oldParallelism int) : Tuple2<Collection<KeyedStateHandle>,Collection<KeyedStateHandle>> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type parallelKeyedStatesBackend : List<KeyedStateHandle> to oldManagedOperatorStates : List<List<OperatorStateHandle>> in method private reDistributePartitionableStates(operatorStates List<OperatorState>, newParallelism int, newManagedOperatorStates List<List<Collection<OperatorStateHandle>>>, newRawOperatorStates List<List<Collection<OperatorStateHandle>>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type state : TaskState to state : OperatorState in method public testCompletedCheckpointStatsCallbacks() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointTest |
From |
To |
|
Change Variable Type subtaskKeyGroupIds : KeyGroupRange to operatorState : OperatorState in method private assignAttemptState(executionJobVertex ExecutionJobVertex, operatorStates List<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type stateForTaskGroup : TaskState to stateForTaskGroup : OperatorState in method public testTriggerSavepointAndResumeWithFileBasedCheckpoints() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type taskStates : Collection<TaskState> to taskStates : Collection<OperatorState> in method public testCheckpointWithOnlyTaskState() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2SerializerTest |
From |
To |
|
Change Variable Type jobVertexId : JobVertexID to jobVertexId : OperatorID in method public deserialize(dis DataInputStream, cl ClassLoader) : SavepointV2 in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer |
From |
To |
|
Change Variable Type taskStates : ArrayList<TaskState> to operatorStates : List<OperatorState> in method public deserialize(dis DataInputStream, cl ClassLoader) : SavepointV2 in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer |
From |
To |
|
Change Variable Type taskState : TaskState to operatorState : OperatorState in method public testAddCheckpointMoreThanMaxRetained() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type taskStates : Collection<TaskState> to taskStates : Collection<OperatorState> in method public testCheckpointWithNoState() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2SerializerTest |
From |
To |
|
Change Variable Type taskStates : Collection<TaskState> to taskStates : Collection<OperatorState> in method public testSuspendDiscardsCheckpoints() : void in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type state : TaskState to state : OperatorState in method public testDiscard() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointTest |
From |
To |
|
Change Variable Type streamTaskState : ChainedStateHandle<StreamStateHandle> to streamTaskState : StreamStateHandle in method public testTriggerSavepointAndResumeWithFileBasedCheckpoints() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type entry : Map.Entry<Integer,SubtaskState> to entry : Map.Entry<Integer,OperatorSubtaskState> in method public serialize(checkpointMetadata SavepointV2, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer |
From |
To |
|
Change Variable Type subtaskState : SubtaskState to subtaskState : OperatorSubtaskState in method protected verifyCheckpointDiscarded(operatorStates Collection<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type taskState : TaskState to operatorState : OperatorState in method public acknowledgeTask(executionAttemptId ExecutionAttemptID, subtaskState SubtaskState, metrics CheckpointMetrics) : TaskAcknowledgeResult in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Change Variable Type taskState : TaskState to operatorState : OperatorState in method protected verifyCheckpointRegistered(operatorStates Collection<OperatorState>, registry SharedStateRegistry) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type taskStates : Collection<TaskState> to operatorStates : Collection<OperatorState> in method public serialize(checkpointMetadata SavepointV2, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer |
From |
To |
|
Change Variable Type taskStates : Collection<TaskState> to operatorStates : Collection<OperatorState> in method public testCheckpointWithOnlyMasterState() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2SerializerTest |
From |
To |
|
Change Variable Type state : TaskState to state : OperatorState in method private completePendingCheckpoint(pendingCheckpoint PendingCheckpoint) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Change Variable Type subtaskState : SubtaskState to subtaskState : OperatorSubtaskState in method protected verifyCheckpointRegistered(operatorStates Collection<OperatorState>, registry SharedStateRegistry) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type taskStates : Collection<TaskState> to taskStates : Collection<OperatorState> in method public testAddCheckpointMoreThanMaxRetained() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type taskStates : Map<JobVertexID,TaskState> to operatorStates : Map<OperatorID,OperatorState> in method public testCleanUpOnSubsume() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointTest |
From |
To |
|
Change Variable Type subtaskState : SubtaskState to subtaskState : OperatorSubtaskState in method protected resetCheckpoint(operatorStates Collection<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type taskStates : Map<JobVertexID,TaskState> to taskStates : Map<OperatorID,OperatorState> in method public testLoadAndValidateSavepoint() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointLoaderTest |
From |
To |
|
Change Variable Type taskStates : Map<JobVertexID,TaskState> to operatorStates : Map<OperatorID,OperatorState> in method public testCleanUpOnShutdown() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointTest |
From |
To |
|
Change Variable Type parallelKeyedStateStream : List<KeyedStateHandle> to oldRawOperatorStates : List<List<OperatorStateHandle>> in method private reDistributePartitionableStates(operatorStates List<OperatorState>, newParallelism int, newManagedOperatorStates List<List<Collection<OperatorStateHandle>>>, newRawOperatorStates List<List<Collection<OperatorStateHandle>>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type subtaskState : SubtaskState to subtaskState : OperatorSubtaskState in method public testAddCheckpointMoreThanMaxRetained() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type newKeyedStateStream : List<KeyedStateHandle> to subManagedKeyedState : Collection<KeyedStateHandle> in method private reAssignSubKeyedStates(operatorState OperatorState, keyGroupPartitions List<KeyGroupRange>, subTaskIndex int, newParallelism int, oldParallelism int) : Tuple2<Collection<KeyedStateHandle>,Collection<KeyedStateHandle>> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type checkpointTaskStates : Map<JobVertexID,TaskState> to checkpointTaskStates : Map<OperatorID,OperatorState> in method public testNonRestoredState() : void in class org.apache.flink.runtime.checkpoint.CheckpointStateRestoreTest |
From |
To |
|
Change Variable Type taskStates : Collection<TaskState> to taskStates : Collection<OperatorState> in method public testCheckpointWithMasterAndTaskState() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2SerializerTest |
From |
To |
|
Change Variable Type state : TaskState to state : OperatorState in method public testLoadAndValidateSavepoint() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointLoaderTest |
From |
To |
|
Change Variable Type state : TaskState to state : OperatorState in method public testCleanUpOnShutdown() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointTest |
From |
To |
|
Change Variable Type taskStates : Map<JobVertexID,TaskState> to taskStates : Map<OperatorID,OperatorState> in method public testDiscard() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointTest |
From |
To |
|
Change Variable Type taskState : TaskState to taskState : OperatorState in method public testRestoreLatestCheckpointedState() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type taskStates : Map<JobVertexID,TaskState> to taskStates : Map<OperatorID,OperatorState> in method package setTaskState(pending PendingCheckpoint, state OperatorState) : void in class org.apache.flink.runtime.checkpoint.PendingCheckpointTest |
From |
To |
|
Change Variable Type taskState : TaskState to operatorState : OperatorState in method public testTriggerSavepointAndResumeWithFileBasedCheckpoints() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type taskState : TaskState to operatorState : OperatorState in method public loadAndValidateSavepoint(jobId JobID, tasks Map<JobVertexID,ExecutionJobVertex>, savepointPath String, classLoader ClassLoader, allowNonRestoredState boolean) : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointLoader |
From |
To |
|
Change Variable Type serializedState : ChainedStateHandle<StreamStateHandle> to serializedState : StreamStateHandle in method public testNonRestoredState() : void in class org.apache.flink.runtime.checkpoint.CheckpointStateRestoreTest |
From |
To |
|
Change Variable Type taskStates : Map<JobVertexID,TaskState> to operatorStates : Map<OperatorID,OperatorState> in method public restoreLatestCheckpointedState(tasks Map<JobVertexID,ExecutionJobVertex>, errorIfNoCheckpoint boolean, allowNonRestoredState boolean) : boolean in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Change Variable Type tasks : Map<JobVertexID,ExecutionJobVertex> to operatorToJobVertexMapping : Map<OperatorID,ExecutionJobVertex> in method public loadAndValidateSavepoint(jobId JobID, tasks Map<JobVertexID,ExecutionJobVertex>, savepointPath String, classLoader ClassLoader, allowNonRestoredState boolean) : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.savepoint.SavepointLoader |
From |
To |
|
Change Variable Type subtaskState : SubtaskState to subtaskState : OperatorSubtaskState in method public testRestoreLatestCheckpointedState() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type taskStates : Collection<TaskState> to operatorStates : Collection<OperatorState> in method public testShutdownDiscardsCheckpoints() : void in class org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type subtaskState : SubtaskState to subtaskState : OperatorSubtaskState in method public testTriggerSavepointAndResumeWithFileBasedCheckpoints() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type taskState : TaskState to operatorState : OperatorState in method protected verifyCheckpointDiscarded(operatorStates Collection<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |
|
Change Variable Type taskState : TaskState to operatorState : OperatorState in method public dispose() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2 |
From |
To |
|
Change Variable Type taskStates : Map<JobVertexID,TaskState> to operatorStates : Map<OperatorID,OperatorState> in method public testCompletedCheckpointStatsCallbacks() : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointTest |
From |
To |
|
Change Variable Type taskState : TaskState to operatorState : OperatorState in method protected resetCheckpoint(operatorStates Collection<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.CompletedCheckpointStoreTest |
From |
To |