|
Change Parameter Type subtaskState : SubtaskState to subtaskState : TaskStateSnapshot in method public acknowledgeCheckpoint(jobID JobID, executionAttemptID ExecutionAttemptID, checkpointId long, checkpointMetrics CheckpointMetrics, subtaskState TaskStateSnapshot) : void in class org.apache.flink.runtime.taskmanager.CheckpointResponder |
From |
To |
|
Change Parameter Type taskStateHandles : TaskStateHandles to taskStateHandles : TaskStateSnapshot in method public TaskDeploymentDescriptor(serializedJobInformation SerializedValue<JobInformation>, serializedTaskInformation SerializedValue<TaskInformation>, executionAttemptId ExecutionAttemptID, allocationId AllocationID, subtaskIndex int, attemptNumber int, targetSlotNumber int, taskStateHandles TaskStateSnapshot, resultPartitionDeploymentDescriptors Collection<ResultPartitionDeploymentDescriptor>, inputGateDeploymentDescriptors Collection<InputGateDeploymentDescriptor>) in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor |
From |
To |
|
Change Parameter Type subtaskState : SubtaskState to subtaskState : TaskStateSnapshot in method public acknowledgeCheckpoint(jobID JobID, executionAttemptID ExecutionAttemptID, checkpointId long, checkpointMetrics CheckpointMetrics, subtaskState TaskStateSnapshot) : void in class org.apache.flink.runtime.taskexecutor.rpc.RpcCheckpointResponder |
From |
To |
|
Change Parameter Type subtaskState : SubtaskState to subtaskState : TaskStateSnapshot in method public acknowledgeCheckpoint(jobID JobID, executionAttemptID ExecutionAttemptID, checkpointId long, checkpointMetrics CheckpointMetrics, subtaskState TaskStateSnapshot) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorGateway |
From |
To |
|
Change Parameter Type checkpointStateHandles : TaskStateHandles to checkpointStateHandles : TaskStateSnapshot in method public setInitialState(checkpointStateHandles TaskStateSnapshot) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Parameter Type stateHandles : OperatorStateHandles to stateHandles : OperatorSubtaskState in method public initializeState(stateHandles OperatorSubtaskState) : void in class org.apache.flink.streaming.api.operators.StreamOperator |
From |
To |
|
Change Parameter Type subtaskState : SubtaskState to subtaskState : TaskStateSnapshot in method public acknowledgeCheckpoint(checkpointId long, checkpointMetrics CheckpointMetrics, subtaskState TaskStateSnapshot) : void in class org.apache.flink.runtime.execution.Environment |
From |
To |
|
Change Parameter Type checkpointStateHandles : SubtaskState to checkpointStateHandles : TaskStateSnapshot in method public acknowledgeCheckpoint(checkpointId long, checkpointMetrics CheckpointMetrics, checkpointStateHandles TaskStateSnapshot) : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.AcknowledgeStreamMockEnvironment |
From |
To |
|
Change Parameter Type checkpointStateHandles : SubtaskState to checkpointStateHandles : TaskStateSnapshot in method public acknowledgeCheckpoint(checkpointId long, checkpointMetrics CheckpointMetrics, checkpointStateHandles TaskStateSnapshot) : void in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment |
From |
To |
|
Change Parameter Type checkpointState : SubtaskState to checkpointState : TaskStateSnapshot in method public acknowledgeCheckpoint(jobID JobID, executionAttemptID ExecutionAttemptID, checkpointId long, checkpointMetrics CheckpointMetrics, checkpointState TaskStateSnapshot) : void in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Parameter Type subtaskState : SubtaskState to subtaskState : TaskStateSnapshot in method public AcknowledgeCheckpoint(job JobID, taskExecutionId ExecutionAttemptID, checkpointId long, checkpointMetrics CheckpointMetrics, subtaskState TaskStateSnapshot) in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint |
From |
To |
|
Change Parameter Type stateHandles : OperatorStateHandles to stateHandles : OperatorSubtaskState in method private restoreStreamCheckpointed(stateHandles OperatorSubtaskState) : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Parameter Type taskStateHandles : TaskStateHandles to taskStateHandles : TaskStateSnapshot in method public setInitialState(taskStateHandles TaskStateSnapshot) : void in class org.apache.flink.runtime.jobgraph.tasks.StatefulTask |
From |
To |
|
Change Parameter Type taskStateHandles : TaskStateHandles to taskStateHandles : TaskStateSnapshot in method public setInitialState(taskStateHandles TaskStateSnapshot) : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTest.ValidatingCheckpointHandler |
From |
To |
|
Change Parameter Type taskStateHandles : TaskStateHandles to taskStateHandles : TaskStateSnapshot in method package createDeploymentDescriptor(executionId ExecutionAttemptID, targetSlot SimpleSlot, taskStateHandles TaskStateSnapshot, attemptNumber int) : TaskDeploymentDescriptor in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Parameter Type taskStateHandles : TaskStateHandles to taskStateHandles : TaskStateSnapshot in method public setInitialState(taskStateHandles TaskStateSnapshot) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Parameter Type subtaskState : SubtaskState to subtaskState : TaskStateSnapshot in method public acknowledgeCheckpoint(checkpointId long, checkpointMetrics CheckpointMetrics, subtaskState TaskStateSnapshot) : void in class org.apache.flink.runtime.operators.testutils.MockEnvironment |
From |
To |
|
Change Parameter Type subtaskState : SubtaskState to subtaskState : TaskStateSnapshot in method private discardSubtaskState(jobId JobID, executionAttemptID ExecutionAttemptID, checkpointId long, subtaskState TaskStateSnapshot) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Change Parameter Type taskStateHandles : TaskStateHandles to taskStateHandles : TaskStateSnapshot in method public Task(jobInformation JobInformation, taskInformation TaskInformation, executionAttemptID ExecutionAttemptID, slotAllocationId AllocationID, subtaskIndex int, attemptNumber int, resultPartitionDeploymentDescriptors Collection<ResultPartitionDeploymentDescriptor>, inputGateDeploymentDescriptors Collection<InputGateDeploymentDescriptor>, targetSlotNumber int, taskStateHandles TaskStateSnapshot, memManager MemoryManager, ioManager IOManager, networkEnvironment NetworkEnvironment, bcVarManager BroadcastVariableManager, taskManagerActions TaskManagerActions, inputSplitProvider InputSplitProvider, checkpointResponder CheckpointResponder, libraryCache LibraryCacheManager, fileCache FileCache, taskManagerConfig TaskManagerRuntimeInfo, metricGroup TaskMetricGroup, resultPartitionConsumableNotifier ResultPartitionConsumableNotifier, partitionProducerStateChecker PartitionProducerStateChecker, executor Executor) in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Parameter Type subtaskState : SubtaskState to operatorSubtaskStates : TaskStateSnapshot in method public acknowledgeTask(executionAttemptId ExecutionAttemptID, operatorSubtaskStates TaskStateSnapshot, metrics CheckpointMetrics) : TaskAcknowledgeResult in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Change Parameter Type checkpointStateHandles : SubtaskState to checkpointStateHandles : TaskStateSnapshot in method public acknowledgeCheckpoint(checkpointId long, checkpointMetrics CheckpointMetrics, checkpointStateHandles TaskStateSnapshot) : void in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTaskTest.AcknowledgeStreamMockEnvironment |
From |
To |
|
Change Parameter Type checkpointStateHandles : SubtaskState to checkpointStateHandles : TaskStateSnapshot in method public acknowledgeCheckpoint(jobID JobID, executionAttemptID ExecutionAttemptID, checkpointId long, checkpointMetrics CheckpointMetrics, checkpointStateHandles TaskStateSnapshot) : void in class org.apache.flink.runtime.taskmanager.ActorGatewayCheckpointResponder |
From |
To |
|
Change Parameter Type stateHandles : OperatorStateHandles to stateHandles : OperatorSubtaskState in method public initializeState(stateHandles OperatorSubtaskState) : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Parameter Type taskStateHandles : TaskStateHandles to taskStateHandles : TaskStateSnapshot in method public setInitialState(taskStateHandles TaskStateSnapshot) : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest.CheckpointSequenceValidator |
From |
To |
|
Change Parameter Type taskStateHandles : TaskStateHandles to taskStateHandles : TaskStateSnapshot in method public setInitialState(taskStateHandles TaskStateSnapshot) : void in class org.apache.flink.runtime.jobmanager.JobManagerHARecoveryTest.BlockingStatefulInvokable |
From |
To |
|
Change Variable Type valueSizeTuple : ChainedStateHandle<StreamStateHandle> to valueSizeTuple : StreamStateHandle in method public testRestoreLatestCheckpointFailureWhenParallelismChanges() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type subtaskStateCaptor : ArgumentCaptor<SubtaskState> to subtaskStateCaptor : ArgumentCaptor<TaskStateSnapshot> in method public testAsyncCheckpointingConcurrentCloseAfterAcknowledge() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Change Variable Type opStateBackend : ChainedStateHandle<OperatorStateHandle> to opStateBackend : OperatorStateHandle in method private testRestoreLatestCheckpointedStateWithChangingParallelism(scaleOut boolean) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type expectedRawOpState : ChainedStateHandle<OperatorStateHandle> to expectedRawOpState : OperatorStateHandle in method public testStateRecoveryWithTopologyChange(scaleType int) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type chainedManagedHandle : ChainedStateHandle<OperatorStateHandle> to operatorSubtaskState : OperatorSubtaskState in method public testFailingCompletedCheckpointStoreAdd() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorFailureTest |
From |
To |
|
Change Variable Type valueSizeTuple : ChainedStateHandle<StreamStateHandle> to valueSizeTuple : StreamStateHandle in method public testRestoreLatestCheckpointFailureWhenMaxParallelismChanges() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type expectSubNonPartitionedState : ChainedStateHandle<StreamStateHandle> to expectSubNonPartitionedState : StreamStateHandle in method public testStateRecoveryWithTopologyChange(scaleType int) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type opStateRaw : ChainedStateHandle<OperatorStateHandle> to opStateRaw : OperatorStateHandle in method private testRestoreLatestCheckpointedStateWithChangingParallelism(scaleOut boolean) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type operatorStateStream : List<Collection<OperatorStateHandle>> to operatorStateStream : Collection<OperatorStateHandle> in method private createTask(streamConfig StreamConfig, taskConfig Configuration, state StreamStateHandle, mode int) : Task in class org.apache.flink.streaming.runtime.tasks.InterruptSensitiveRestoreTest |
From |
To |
|
Change Variable Type matcher : BaseMatcher<TaskStateHandles> to matcher : BaseMatcher<TaskStateSnapshot> in method public testSetState() : void in class org.apache.flink.runtime.checkpoint.CheckpointStateRestoreTest |
From |
To |
|
Change Variable Type taskStateHandles : TaskStateHandles to taskState : TaskStateSnapshot in method private assignAttemptState(executionJobVertex ExecutionJobVertex, operatorStates List<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type taskStateHandles : TaskStateHandles to taskStateHandles : TaskStateSnapshot in method private testRestoreLatestCheckpointedStateWithChangingParallelism(scaleOut boolean) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type that : TaskStateHandles to that : TaskStateSnapshot in method public equals(o Object) : boolean in class org.apache.flink.runtime.checkpoint.TaskStateSnapshot |
From |
To |
|
Change Variable Type unknownSubtaskState2 : SubtaskState to unknownSubtaskState2 : TaskStateSnapshot in method public testStateCleanupForLateOrUnknownMessages() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type partitionableState : ChainedStateHandle<OperatorStateHandle> to partitionableState : OperatorStateHandle in method package mockSubtaskState(jobVertexID JobVertexID, index int, keyGroupRange KeyGroupRange) : TaskStateSnapshot in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type taskStateHandles : TaskStateHandles to taskStateHandles : TaskStateSnapshot in method public testSerialization() : void in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptorTest |
From |
To |
|
Change Variable Type nonPartitionedState : ChainedStateHandle<StreamStateHandle> to nonPartitionedState : StreamStateHandle in method package mockSubtaskState(jobVertexID JobVertexID, index int, keyGroupRange KeyGroupRange) : TaskStateSnapshot in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type ackSubtaskState : SubtaskState to ackSubtaskState : TaskStateSnapshot in method public testStateCleanupForLateOrUnknownMessages() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type operatorState : ChainedStateHandle<StreamStateHandle> to operatorState : StreamStateHandle in method private createTask(streamConfig StreamConfig, taskConfig Configuration, state StreamStateHandle, mode int) : Task in class org.apache.flink.streaming.runtime.tasks.InterruptSensitiveRestoreTest |
From |
To |
|
Change Variable Type keyedStateFromBackend : List<KeyedStateHandle> to keyedStateFromBackend : Collection<KeyedStateHandle> in method private createTask(streamConfig StreamConfig, taskConfig Configuration, state StreamStateHandle, mode int) : Task in class org.apache.flink.streaming.runtime.tasks.InterruptSensitiveRestoreTest |
From |
To |
|
Change Variable Type state : ChainedStateHandle<StreamStateHandle> to state : StreamStateHandle in method public testRestoreLatestCheckpointFailureWhenParallelismChanges() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type taskStateHandles : TaskStateHandles to stateSnapshot : TaskStateSnapshot in method public testStateRecoveryWithTopologyChange(scaleType int) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type keyedStateFromStream : List<KeyedStateHandle> to keyedStateFromStream : Collection<KeyedStateHandle> in method private createTask(streamConfig StreamConfig, taskConfig Configuration, state StreamStateHandle, mode int) : Task in class org.apache.flink.streaming.runtime.tasks.InterruptSensitiveRestoreTest |
From |
To |
|
Change Variable Type unknownSubtaskState : SubtaskState to unknownSubtaskState : TaskStateSnapshot in method public testStateCleanupForLateOrUnknownMessages() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type triggerSubtaskState : SubtaskState to triggerSubtaskState : TaskStateSnapshot in method public testStateCleanupForLateOrUnknownMessages() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type opStateBackend : List<Collection<OperatorStateHandle>> to opStateBackend : Collection<OperatorStateHandle> in method private testRestoreLatestCheckpointedStateWithChangingParallelism(scaleOut boolean) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type operatorStateBackend : List<Collection<OperatorStateHandle>> to operatorStateBackend : Collection<OperatorStateHandle> in method private createTask(streamConfig StreamConfig, taskConfig Configuration, state StreamStateHandle, mode int) : Task in class org.apache.flink.streaming.runtime.tasks.InterruptSensitiveRestoreTest |
From |
To |
|
Change Variable Type valueSizeTuple : ChainedStateHandle<StreamStateHandle> to valueSizeTuple : StreamStateHandle in method private testRestoreLatestCheckpointedStateWithChangingParallelism(scaleOut boolean) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type differentJobSubtaskState : SubtaskState to differentJobSubtaskState : TaskStateSnapshot in method public testStateCleanupForLateOrUnknownMessages() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type expectedManagedOpState : ChainedStateHandle<OperatorStateHandle> to expectedManagedOpState : OperatorStateHandle in method public testStateRecoveryWithTopologyChange(scaleType int) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type subtaskState1_3 : SubtaskState to subtaskState1_3 : OperatorSubtaskState in method public testSuccessfulCheckpointSubsumesUnsuccessful() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type subtaskState : SubtaskState to subtaskState : TaskStateSnapshot in method public testRestoreLatestCheckpointedState() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type expectNonPartitionedState : ChainedStateHandle<StreamStateHandle> to expectNonPartitionedState : StreamStateHandle in method public verifyStateRestore(jobVertexID JobVertexID, executionJobVertex ExecutionJobVertex, keyGroupPartitions List<KeyGroupRange>) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type taskStateHandles : TaskStateHandles to stateSnapshot : TaskStateSnapshot in method public verifyStateRestore(jobVertexID JobVertexID, executionJobVertex ExecutionJobVertex, keyGroupPartitions List<KeyGroupRange>) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type opStateRaw : List<Collection<OperatorStateHandle>> to opStateRaw : Collection<OperatorStateHandle> in method private testRestoreLatestCheckpointedStateWithChangingParallelism(scaleOut boolean) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Rename Variable subtaskState : OperatorSubtaskState to subtaskState1 : OperatorSubtaskState in method public testCheckpointTimeoutIsolated() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Rename Variable rawHandle : OperatorStateHandle to rawOpHandle : OperatorStateHandle in method public testFailingCompletedCheckpointStoreAdd() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorFailureTest |
From |
To |
|
Rename Variable subtaskKeyedStateHandles : List<KeyedStateHandle> to extractedKeyedStateHandles : List<KeyedStateHandle> in method public getRawKeyedStateHandles(operatorState OperatorState, subtaskKeyGroupRange KeyGroupRange) : List<KeyedStateHandle> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Rename Variable taskStateHandles : TaskStateHandles to stateSnapshot : TaskStateSnapshot in method public testStateRecoveryWithTopologyChange(scaleType int) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Rename Variable storedTriggerSubtaskState : OperatorSubtaskState to subtaskStateTrigger : OperatorSubtaskState in method public testStateCleanupForLateOrUnknownMessages() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Rename Variable managedHandle : OperatorStateHandle to managedOpHandle : OperatorStateHandle in method public testFailingCompletedCheckpointStoreAdd() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorFailureTest |
From |
To |
|
Rename Variable chainedManagedHandle : ChainedStateHandle<OperatorStateHandle> to operatorSubtaskState : OperatorSubtaskState in method public testFailingCompletedCheckpointStoreAdd() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorFailureTest |
From |
To |
|
Rename Variable taskStateHandles : TaskStateHandles to stateSnapshot : TaskStateSnapshot in method public verifyStateRestore(jobVertexID JobVertexID, executionJobVertex ExecutionJobVertex, keyGroupPartitions List<KeyGroupRange>) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Rename Variable cfg : StreamConfig to streamConfig : StreamConfig in method private testRestoreWithInterrupt(mode int) : void in class org.apache.flink.streaming.runtime.tasks.InterruptSensitiveRestoreTest |
From |
To |
|
Rename Variable managedRawHandle : KeyedStateHandle to rawKeyedHandle : KeyedStateHandle in method public testFailingCompletedCheckpointStoreAdd() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorFailureTest |
From |
To |
|
Rename Variable taskStateHandles : TaskStateHandles to taskState : TaskStateSnapshot in method private assignAttemptState(executionJobVertex ExecutionJobVertex, operatorStates List<OperatorState>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Return Type SubtaskState to TaskStateSnapshot in method public getSubtaskState() : TaskStateSnapshot in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint |
From |
To |
|
Change Return Type KeyedStateHandle to Collection<KeyedStateHandle> in method public getManagedKeyedState() : Collection<KeyedStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Return Type OperatorStateHandle to Collection<OperatorStateHandle> in method public getRawOperatorState() : Collection<OperatorStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Return Type TaskStateHandles to TaskStateSnapshot in method public getTaskStateSnapshot() : TaskStateSnapshot in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Return Type SubtaskState to TaskStateSnapshot in method package mockSubtaskState(jobVertexID JobVertexID, index int, keyGroupRange KeyGroupRange) : TaskStateSnapshot in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Return Type SubtaskState to TaskStateSnapshot in method public getCheckpointStateHandles() : TaskStateSnapshot in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.AcknowledgeStreamMockEnvironment |
From |
To |
|
Change Return Type OperatorStateHandle to Collection<OperatorStateHandle> in method public getManagedOperatorState() : Collection<OperatorStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Return Type TaskStateHandles to TaskStateSnapshot in method public getTaskStateHandles() : TaskStateSnapshot in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor |
From |
To |
|
Change Return Type ChainedStateHandle<StreamStateHandle> to StreamStateHandle in method public generateStateForVertex(jobVertexID JobVertexID, index int) : StreamStateHandle in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Return Type ChainedStateHandle<OperatorStateHandle> to OperatorStateHandle in method private generatePartitionableStateHandle(states Map<String,List<? extends Serializable>>) : OperatorStateHandle in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Return Type SubtaskState to TaskStateSnapshot in method public getCheckpointStateHandles() : TaskStateSnapshot in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTaskTest.AcknowledgeStreamMockEnvironment |
From |
To |
|
Change Return Type KeyedStateHandle to Collection<KeyedStateHandle> in method public getRawKeyedState() : Collection<KeyedStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Attribute Type managedOperatorState : OperatorStateHandle to managedOperatorState : Collection<OperatorStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Attribute Type checkpointStateHandles : SubtaskState to checkpointStateHandles : TaskStateSnapshot in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTaskTest.AcknowledgeStreamMockEnvironment |
From |
To |
|
Change Attribute Type checkpointStateHandles : SubtaskState to checkpointStateHandles : TaskStateSnapshot in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest.AcknowledgeStreamMockEnvironment |
From |
To |
|
Change Attribute Type nonPartitionedStates : List<StreamStateHandle> to nonPartitionedStates : Map<OperatorID,StreamStateHandle> in class org.apache.flink.streaming.runtime.tasks.StreamTask.CheckpointingOperation |
From |
To |
|
Change Attribute Type subtaskState : SubtaskState to subtaskState : TaskStateSnapshot in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint |
From |
To |
|
Change Attribute Type snapshotInProgressList : List<OperatorSnapshotResult> to operatorSnapshotsInProgress : Map<OperatorID,OperatorSnapshotResult> in class org.apache.flink.streaming.runtime.tasks.StreamTask.CheckpointingOperation |
From |
To |
|
Change Attribute Type managedKeyedState : KeyedStateHandle to managedKeyedState : Collection<KeyedStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Attribute Type rawKeyedState : KeyedStateHandle to rawKeyedState : Collection<KeyedStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Attribute Type taskStateHandles : TaskStateHandles to taskStateHandles : TaskStateSnapshot in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor |
From |
To |
|
Change Attribute Type restoreStateHandles : TaskStateHandles to taskStateSnapshot : TaskStateSnapshot in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Attribute Type nonPartitionedStateHandles : List<StreamStateHandle> to nonPartitionedStateHandles : Map<OperatorID,StreamStateHandle> in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable |
From |
To |
|
Change Attribute Type taskStateHandles : TaskStateHandles to taskStateHandles : TaskStateSnapshot in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Attribute Type rawOperatorState : OperatorStateHandle to rawOperatorState : Collection<OperatorStateHandle> in class org.apache.flink.runtime.checkpoint.OperatorSubtaskState |
From |
To |
|
Change Attribute Type taskState : TaskStateHandles to taskState : TaskStateSnapshot in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |