|
Change Parameter Type checkpointStateHandles : CheckpointStateHandles to subtaskState : SubtaskState in method public acknowledgeCheckpoint(jobID JobID, executionAttemptID ExecutionAttemptID, checkpointMetaData CheckpointMetaData, subtaskState SubtaskState) : void in class org.apache.flink.runtime.taskmanager.CheckpointResponder |
From |
To |
|
Change Parameter Type restoredState : List<KeyGroupsStateHandle> to restoredState : Collection<KeyGroupsStateHandle> in method public abstract restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState Collection<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.AbstractStateBackend |
From |
To |
|
Change Parameter Type partitionedOperatorState : boolean to checkpointMethod : OperatorCheckpointMethod in method private createJobGraphWithOperatorState(parallelism int, maxParallelism int, checkpointMethod OperatorCheckpointMethod) : JobGraph in class org.apache.flink.test.checkpointing.RescalingITCase |
From |
To |
|
Change Parameter Type keyGroupsStateHandles : List<KeyGroupsStateHandle> to keyGroupsStateHandles : Collection<KeyGroupsStateHandle> in method public doRestore(keyGroupsStateHandles Collection<KeyGroupsStateHandle>) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBRestoreOperation |
From |
To |
|
Change Parameter Type restoredState : List<KeyGroupsStateHandle> to restoredState : Collection<KeyGroupsStateHandle> in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState Collection<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.memory.MemoryStateBackend |
From |
To |
|
Change Parameter Type restoreState : List<KeyGroupsStateHandle> to restoreState : Collection<KeyGroupsStateHandle> in method public RocksDBKeyedStateBackend(jobId JobID, operatorIdentifier String, userCodeClassLoader ClassLoader, instanceBasePath File, dbOptions DBOptions, columnFamilyOptions ColumnFamilyOptions, kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoreState Collection<KeyGroupsStateHandle>) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Parameter Type stateStore : OperatorStateStore to context : FunctionInitializationContext in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase |
From |
To |
|
Change Parameter Type restoredState : List<KeyGroupsStateHandle> to restoredState : Collection<KeyGroupsStateHandle> in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState Collection<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend |
From |
To |
|
Change Parameter Type checkpointStateHandles : CheckpointStateHandles to subtaskState : SubtaskState in method public acknowledgeCheckpoint(checkpointMetaData CheckpointMetaData, subtaskState SubtaskState) : void in class org.apache.flink.runtime.execution.Environment |
From |
To |
|
Change Parameter Type record : StreamRecord to record : StreamRecord<T> in method private setKeyContextElement(record StreamRecord<T>, selector KeySelector<T,?>) : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Parameter Type stateStore : OperatorStateStore to context : FunctionInitializationContext in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.api.checkpoint.CheckpointedFunction |
From |
To |
|
Change Parameter Type actualPartitionedKeyGroupState : List<KeyGroupsStateHandle> to actualPartitionedKeyGroupState : Collection<KeyGroupsStateHandle> in method public compareKeyedState(expectPartitionedKeyGroupState Collection<KeyGroupsStateHandle>, actualPartitionedKeyGroupState Collection<KeyGroupsStateHandle>) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Parameter Type checkpointStateHandles : CheckpointStateHandles to checkpointStateHandles : SubtaskState in method public acknowledgeCheckpoint(jobID JobID, executionAttemptID ExecutionAttemptID, checkpointMetaData CheckpointMetaData, checkpointStateHandles SubtaskState) : void in class org.apache.flink.runtime.taskmanager.ActorGatewayCheckpointResponder |
From |
To |
|
Change Parameter Type checkpointStateHandles : CheckpointStateHandles to checkpointedSubtaskState : SubtaskState in method public acknowledgeTask(attemptID ExecutionAttemptID, checkpointedSubtaskState SubtaskState) : boolean in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Change Parameter Type selector : KeySelector<?,?> to selector : KeySelector<T,?> in method private setKeyContextElement(record StreamRecord<T>, selector KeySelector<T,?>) : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Parameter Type restoredState : List<KeyGroupsStateHandle> to restoredState : Collection<KeyGroupsStateHandle> in method public HeapKeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, userCodeClassLoader ClassLoader, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState Collection<KeyGroupsStateHandle>) in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Parameter Type nonPartitionedStateHandles : ChainedStateHandle<StreamStateHandle> to nonPartitionedStateHandles : List<StreamStateHandle> in method package AsyncCheckpointRunnable(owner StreamTask<?,?>, nonPartitionedStateHandles List<StreamStateHandle>, snapshotInProgressList List<OperatorSnapshotResult>, checkpointMetaData CheckpointMetaData, asyncStartNanos long) in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable |
From |
To |
|
Change Parameter Type checkpointStateHandles : CheckpointStateHandles to subtaskState : SubtaskState in method public AcknowledgeCheckpoint(job JobID, taskExecutionId ExecutionAttemptID, checkpointMetaData CheckpointMetaData, subtaskState SubtaskState) in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint |
From |
To |
|
Change Parameter Type restoredState : List<KeyGroupsStateHandle> to restoredState : Collection<KeyGroupsStateHandle> in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState Collection<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.test.streaming.runtime.StateBackendITCase.FailingStateBackend |
From |
To |
|
Change Parameter Type state : List<KeyGroupsStateHandle> to state : Collection<KeyGroupsStateHandle> in method private restorePartitionedState(state Collection<KeyGroupsStateHandle>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Parameter Type restoredState : List<KeyGroupsStateHandle> to restoredState : Collection<KeyGroupsStateHandle> in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState Collection<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : AbstractKeyedStateBackend<K> in class org.apache.flink.runtime.state.filesystem.FsStateBackend |
From |
To |
|
Change Parameter Type expectPartitionedKeyGroupState : List<KeyGroupsStateHandle> to expectPartitionedKeyGroupState : Collection<KeyGroupsStateHandle> in method public compareKeyedState(expectPartitionedKeyGroupState Collection<KeyGroupsStateHandle>, actualPartitionedKeyGroupState Collection<KeyGroupsStateHandle>) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Parameter Type checkpointStateHandles : CheckpointStateHandles to checkpointStateHandles : SubtaskState in method public acknowledgeCheckpoint(checkpointMetaData CheckpointMetaData, checkpointStateHandles SubtaskState) : void in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment |
From |
To |
|
Change Variable Type partitionedKeyGroupState : List<KeyGroupsStateHandle> to partitionedKeyGroupState : KeyGroupsStateHandle in method public testRestoreLatestCheckpointedState() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type keyGroupState : List<KeyGroupsStateHandle> to keyGroupState : KeyGroupsStateHandle in method public testRestoreLatestCheckpointFailureWhenParallelismChanges() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type serializedKeyGroupStates : List<KeyGroupsStateHandle> to serializedKeyGroupStates : KeyGroupsStateHandle in method public testSetState() : void in class org.apache.flink.runtime.checkpoint.CheckpointStateRestoreTest |
From |
To |
|
Change Variable Type keyGroupState : List<KeyGroupsStateHandle> to keyGroupState : KeyGroupsStateHandle in method public testRestoreLatestCheckpointFailureWhenMaxParallelismChanges() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type serializedKeyGroupStates : List<KeyGroupsStateHandle> to serializedKeyGroupStates : KeyGroupsStateHandle in method public testStateOnlyPartiallyAvailable() : void in class org.apache.flink.runtime.checkpoint.CheckpointStateRestoreTest |
From |
To |
|
Change Variable Type baos : ByteArrayOutputStream to baos : ByteArrayOutputStreamWithPos in method public testSerializeDeserializeV1() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1SerializerTest |
From |
To |
|
Change Variable Type matcher : BaseMatcher<CheckpointStateHandles> to matcher : BaseMatcher<TaskStateHandles> in method public testSetState() : void in class org.apache.flink.runtime.checkpoint.CheckpointStateRestoreTest |
From |
To |
|
Change Variable Type outStream : CheckpointStreamFactory.CheckpointStateOutputStream to streamFactory : CheckpointStreamFactory in method public snapshot(checkpointId long, timestamp long) : OperatorSnapshotResult in class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Change Variable Type split : List<Integer> to counterPartitions : ListState<Integer> in method public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.test.checkpointing.RescalingITCase.PartitionedStateSource |
From |
To |
|
Change Variable Type keyGroupState : List<KeyGroupsStateHandle> to keyedStateRaw : KeyGroupsStateHandle in method private testRestoreLatestCheckpointedStateWithChangingParallelism(scaleOut boolean) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type originalKeyGroupState : List<KeyGroupsStateHandle> to originalKeyedStateRaw : KeyGroupsStateHandle in method private testRestoreLatestCheckpointedStateWithChangingParallelism(scaleOut boolean) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type checkpointStateHandles : CheckpointStateHandles to stateAssignmentOperation : StateAssignmentOperation in method public restoreLatestCheckpointedState(tasks Map<JobVertexID,ExecutionJobVertex>, errorIfNoCheckpoint boolean, allOrNothingState boolean) : boolean in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Change Variable Type keyGroupsStateHandle : KeyGroupsStateHandle to checkpointedSubtaskState : SubtaskState in method public acknowledgeTask(attemptID ExecutionAttemptID, checkpointedSubtaskState SubtaskState) : boolean in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Change Variable Type expectPartitionedKeyGroupState : List<KeyGroupsStateHandle> to expectPartitionedKeyGroupState : KeyGroupsStateHandle in method public verifiyStateRestore(jobVertexID JobVertexID, executionJobVertex ExecutionJobVertex, keyGroupPartitions List<KeyGroupRange>) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type stateHandle : StreamStateHandle to operatorStateHandleStream : OperatorStateHandle in method package createTaskStates(numTaskStates int, numSubtasksPerTask int) : Collection<TaskState> in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Test |
From |
To |
|
Change Variable Type allStateHandles : CheckpointStateHandles to subtaskState : SubtaskState in method public run() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable |
From |
To |
|
Change Variable Type chkFunction : Checkpointed<Serializable> to chkFunction : CheckpointedRestoring<Serializable> in method public restoreState(in FSDataInputStream) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Rename Method public compareKeyPartitionedState(expectPartitionedKeyGroupState List<KeyGroupsStateHandle>, actualPartitionedKeyGroupState List<KeyGroupsStateHandle>) : void renamed to public compareKeyedState(expectPartitionedKeyGroupState Collection<KeyGroupsStateHandle>, actualPartitionedKeyGroupState Collection<KeyGroupsStateHandle>) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Rename Method public prepareSnapshot(checkpointId long, timestamp long) : void renamed to public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.streaming.api.checkpoint.CheckpointedFunction |
From |
To |
|
Rename Method public getChainedStateHandle() : ChainedStateHandle<StreamStateHandle> renamed to public getRawKeyedState() : KeyGroupsStateHandle in class org.apache.flink.runtime.checkpoint.SubtaskState |
From |
To |
|
Rename Method private setRawKeyContextElement(record StreamRecord, selector KeySelector<?,?>) : void renamed to private setKeyContextElement(record StreamRecord<T>, selector KeySelector<T,?>) : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Rename Method public prepareSnapshot(checkpointId long, timestamp long) : void renamed to public snapshotState(ctx FunctionSnapshotContext) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase |
From |
To |
|
Rename Method public deserializePartitionableStateHandle(dis DataInputStream) : OperatorStateHandle renamed to public deserializeOperatorStateHandle(dis DataInputStream) : OperatorStateHandle in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Serializer |
From |
To |
|
Rename Method public getCheckpointStateHandles() : CheckpointStateHandles renamed to public getSubtaskState() : SubtaskState in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint |
From |
To |
|
Rename Method public serializePartitionableStateHandle(stateHandle OperatorStateHandle, dos DataOutputStream) : void renamed to public serializeOperatorStateHandle(stateHandle OperatorStateHandle, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Serializer |
From |
To |
|
Rename Method public getOperatorState() : ChainedStateHandle<StreamStateHandle> renamed to public getTaskStateHandles() : TaskStateHandles in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor |
From |
To |
|
Rename Method public snapshot(checkpointId long, timestamp long) : StreamStateHandle renamed to public snapshotLegacy(checkpointId long, timestamp long) : StreamStateHandle in class org.apache.flink.streaming.util.KeyedOneInputStreamOperatorTestHarness |
From |
To |
|
Rename Variable partitionableState : List<Collection<OperatorStateHandle>> to opStateBackend : List<Collection<OperatorStateHandle>> in method private testRestoreLatestCheckpointedStateWithChangingParallelism(scaleOut boolean) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Rename Variable chainedStateHandle : ChainedStateHandle<OperatorStateHandle> to operatorStateBackend : ChainedStateHandle<OperatorStateHandle> in method public serializeSubtaskState(subtaskState SubtaskState, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Serializer |
From |
To |
|
Rename Variable outStream : CheckpointStreamFactory.CheckpointStateOutputStream to streamFactory : CheckpointStreamFactory in method public snapshot(checkpointId long, timestamp long) : OperatorSnapshotResult in class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Rename Variable keyGroupState : List<KeyGroupsStateHandle> to keyedStateRaw : KeyGroupsStateHandle in method private testRestoreLatestCheckpointedStateWithChangingParallelism(scaleOut boolean) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Rename Variable originalKeyGroupState : List<KeyGroupsStateHandle> to originalKeyedStateRaw : KeyGroupsStateHandle in method private testRestoreLatestCheckpointedStateWithChangingParallelism(scaleOut boolean) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Rename Variable k : int to i : int in method public deserializeSubtaskState(dis DataInputStream) : SubtaskState in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Serializer |
From |
To |
|
Rename Variable partitionableState : ChainedStateHandle<OperatorStateHandle> to opStateBackend : ChainedStateHandle<OperatorStateHandle> in method private testRestoreLatestCheckpointedStateWithChangingParallelism(scaleOut boolean) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Rename Variable keyGroupsStateHandle : KeyGroupsStateHandle to keyedStateBackend : KeyGroupsStateHandle in method public deserializeSubtaskState(dis DataInputStream) : SubtaskState in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Serializer |
From |
To |
|
Rename Variable chainedStateHandle : ChainedStateHandle<StreamStateHandle> to nonPartitionableState : ChainedStateHandle<StreamStateHandle> in method public serializeSubtaskState(subtaskState SubtaskState, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Serializer |
From |
To |
|
Rename Variable expectedPartitionableState : ChainedStateHandle<OperatorStateHandle> to expectedOpStateBackend : ChainedStateHandle<OperatorStateHandle> in method public verifiyStateRestore(jobVertexID JobVertexID, executionJobVertex ExecutionJobVertex, keyGroupPartitions List<KeyGroupRange>) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Rename Variable checkpointStateHandles : CheckpointStateHandles to stateAssignmentOperation : StateAssignmentOperation in method public restoreLatestCheckpointedState(tasks Map<JobVertexID,ExecutionJobVertex>, errorIfNoCheckpoint boolean, allOrNothingState boolean) : boolean in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Rename Variable j : int to i : int in method public serializeSubtaskState(subtaskState SubtaskState, dos DataOutputStream) : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Serializer |
From |
To |
|
Rename Variable allStateHandles : CheckpointStateHandles to subtaskState : SubtaskState in method public run() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable |
From |
To |
|
Rename Variable stateHandle : StreamStateHandle to operatorStateHandleStream : OperatorStateHandle in method package createTaskStates(numTaskStates int, numSubtasksPerTask int) : Collection<TaskState> in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Test |
From |
To |
|
Rename Variable j : int to subtaskIdx : int in method package createTaskStates(numTaskStates int, numSubtasksPerTask int) : Collection<TaskState> in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Test |
From |
To |
|
Change Return Type RunnableFuture<OperatorStateHandle> to OperatorSnapshotResult in method public snapshotState(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : OperatorSnapshotResult in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Return Type List<KeyGroupsStateHandle> to KeyGroupsStateHandle in method public generateKeyGroupState(keyGroupRange KeyGroupRange, states List<? extends Serializable>) : KeyGroupsStateHandle in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Return Type KeyGroupRange to KeyGroupsList in method public getKeyGroupRange() : KeyGroupsList in class org.apache.flink.runtime.state.KeyedStateBackend |
From |
To |
|
Change Return Type RunnableFuture<OperatorStateHandle> to void in method public snapshotState(context StateSnapshotContext) : void in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTaskTest.TestingStreamOperator |
From |
To |
|
Change Return Type ListState<Serializable> to ListState<T> in method public getSerializableListState(stateName String) : ListState<T> in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Change Return Type ListState<Serializable> to ListState<T> in method public getSerializableListState(stateName String) : ListState<T> in class org.apache.flink.api.common.state.OperatorStateStore |
From |
To |
|
Change Return Type StreamStateHandle to OperatorSnapshotResult in method public snapshot(checkpointId long, timestamp long) : OperatorSnapshotResult in class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Change Return Type ChainedStateHandle<StreamStateHandle> to KeyGroupsStateHandle in method public getRawKeyedState() : KeyGroupsStateHandle in class org.apache.flink.runtime.checkpoint.SubtaskState |
From |
To |
|
Change Return Type ChainedStateHandle<StreamStateHandle> to TaskStateHandles in method public getTaskStateHandles() : TaskStateHandles in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor |
From |
To |
|
Change Return Type List<KeyGroupsStateHandle> to KeyGroupsStateHandle in method public generateKeyGroupState(jobVertexID JobVertexID, keyGroupPartition KeyGroupRange, rawState boolean) : KeyGroupsStateHandle in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Return Type List<Integer> to void in method public snapshotState(context FunctionSnapshotContext) : void in class org.apache.flink.test.checkpointing.RescalingITCase.PartitionedStateSource |
From |
To |
|
Change Return Type CheckpointStateHandles to SubtaskState in method public getSubtaskState() : SubtaskState in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint |
From |
To |
|
Change Return Type RunnableFuture<OperatorStateHandle> to OperatorSnapshotResult in method public snapshotState(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : OperatorSnapshotResult in class org.apache.flink.streaming.api.operators.StreamOperator |
From |
To |
|
Rename Parameter checkpointStateHandles : CheckpointStateHandles to subtaskState : SubtaskState in method public AcknowledgeCheckpoint(job JobID, taskExecutionId ExecutionAttemptID, checkpointMetaData CheckpointMetaData, subtaskState SubtaskState) in class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint |
From |
To |
|
Rename Parameter numSubtaskStates : int to numSubtasksPerTask : int in method package createTaskStates(numTaskStates int, numSubtasksPerTask int) : Collection<TaskState> in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Test |
From |
To |
|
Rename Parameter stateStore : OperatorStateStore to context : FunctionInitializationContext in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase |
From |
To |
|
Rename Parameter checkpointStateHandles : CheckpointStateHandles to subtaskState : SubtaskState in method public acknowledgeCheckpoint(checkpointMetaData CheckpointMetaData, subtaskState SubtaskState) : void in class org.apache.flink.runtime.execution.Environment |
From |
To |
|
Rename Parameter stateStore : OperatorStateStore to context : FunctionInitializationContext in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.api.checkpoint.CheckpointedFunction |
From |
To |
|
Rename Parameter checkpointStateHandles : CheckpointStateHandles to checkpointedSubtaskState : SubtaskState in method public acknowledgeTask(attemptID ExecutionAttemptID, checkpointedSubtaskState SubtaskState) : boolean in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Rename Parameter checkpointStateHandles : CheckpointStateHandles to subtaskState : SubtaskState in method public acknowledgeCheckpoint(jobID JobID, executionAttemptID ExecutionAttemptID, checkpointMetaData CheckpointMetaData, subtaskState SubtaskState) : void in class org.apache.flink.runtime.taskmanager.CheckpointResponder |
From |
To |
|
Rename Parameter partitionedOperatorState : boolean to checkpointMethod : OperatorCheckpointMethod in method private createJobGraphWithOperatorState(parallelism int, maxParallelism int, checkpointMethod OperatorCheckpointMethod) : JobGraph in class org.apache.flink.test.checkpointing.RescalingITCase |
From |
To |
|
Rename Parameter chainedStateHandle : ChainedStateHandle<StreamStateHandle> to legacyOperatorState : ChainedStateHandle<StreamStateHandle> in method public SubtaskState(legacyOperatorState ChainedStateHandle<StreamStateHandle>, managedOperatorState ChainedStateHandle<OperatorStateHandle>, rawOperatorState ChainedStateHandle<OperatorStateHandle>, managedKeyedState KeyGroupsStateHandle, rawKeyedState KeyGroupsStateHandle, duration long) in class org.apache.flink.runtime.checkpoint.SubtaskState |
From |
To |