|
Change Parameter Type externalizedCheckpointSettings : ExternalizedCheckpointSettings to checkpointRetentionPolicy : CheckpointRetentionPolicy in method public CheckpointCoordinatorConfiguration(checkpointInterval long, checkpointTimeout long, minPauseBetweenCheckpoints long, maxConcurrentCheckpoints int, checkpointRetentionPolicy CheckpointRetentionPolicy, isExactlyOnce boolean) in class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration |
From |
To |
|
Change Parameter Type externalizedSettings : ExternalizedCheckpointSettings to retentionPolicy : CheckpointRetentionPolicy in method public GraphAndSettings(graph AccessExecutionGraph, jobCheckpointingConfiguration CheckpointCoordinatorConfiguration, retentionPolicy CheckpointRetentionPolicy) in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest.GraphAndSettings |
From |
To |
|
Change Parameter Type targetDirectory : String to targetLocation : CheckpointStorageLocation in method public PendingCheckpoint(jobId JobID, checkpointId long, checkpointTimestamp long, verticesToConfirm Map<ExecutionAttemptID,ExecutionVertex>, props CheckpointProperties, targetLocation CheckpointStorageLocation, executor Executor) in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |
|
Rename Variable externalizedSettings : ExternalizedCheckpointSettings to retentionPolicy : CheckpointRetentionPolicy in method public testEnabledExternalizedCheckpointSettings() : void in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest |
From |
To |
|
Rename Variable externalization : ExternalizedCheckpointSettings to retentionPolicy : CheckpointRetentionPolicy in method private createCheckpointConfigJson(graph AccessExecutionGraph) : String in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandler |
From |
To |
|
Rename Variable externalizedSetting : ExternalizedCheckpointSettings to retentionPolicy : CheckpointRetentionPolicy in method private createGraphAndSettings(externalized boolean, exactlyOnce boolean) : GraphAndSettings in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest |
From |
To |
|
Rename Variable externalizedCheckpointSettings : ExternalizedCheckpointSettings to retentionPolicy : CheckpointRetentionPolicy in method protected handleRequest(request HandlerRequest<EmptyRequestBody,JobMessageParameters>, executionGraph AccessExecutionGraph) : CheckpointConfigInfo in class org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointConfigHandler |
From |
To |
|
Rename Variable externalizedCheckpointSettings : ExternalizedCheckpointSettings to retentionAfterTermination : CheckpointRetentionPolicy in method private configureCheckpointing() : void in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Rename Variable externalizedSettings : ExternalizedCheckpointSettings to retentionPolicy : CheckpointRetentionPolicy in method public testArchiver() : void in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest |
From |
To |
|
Change Variable Type externalizedSettings : ExternalizedCheckpointSettings to retentionPolicy : CheckpointRetentionPolicy in method public testArchiver() : void in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest |
From |
To |
|
Change Variable Type blockingStateBackend : AbstractStateBackend to blockingStateBackend : StateBackend in method public testConcurrentAsyncCheckpointCannotFailFinishedStreamTask() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTerminationTest |
From |
To |
|
Change Variable Type externalizedSettings : ExternalizedCheckpointSettings to retentionPolicy : CheckpointRetentionPolicy in method public testEnabledExternalizedCheckpointSettings() : void in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest |
From |
To |
|
Change Variable Type externalization : ExternalizedCheckpointSettings to retentionPolicy : CheckpointRetentionPolicy in method private createCheckpointConfigJson(graph AccessExecutionGraph) : String in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandler |
From |
To |
|
Change Variable Type externalizedSetting : ExternalizedCheckpointSettings to retentionPolicy : CheckpointRetentionPolicy in method private createGraphAndSettings(externalized boolean, exactlyOnce boolean) : GraphAndSettings in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest |
From |
To |
|
Change Variable Type externalizedCheckpointSettings : ExternalizedCheckpointSettings to retentionPolicy : CheckpointRetentionPolicy in method protected handleRequest(request HandlerRequest<EmptyRequestBody,JobMessageParameters>, executionGraph AccessExecutionGraph) : CheckpointConfigInfo in class org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointConfigHandler |
From |
To |
|
Change Variable Type externalizedCheckpointSettings : ExternalizedCheckpointSettings to retentionAfterTermination : CheckpointRetentionPolicy in method private configureCheckpointing() : void in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Rename Parameter targetDirectory : String to targetLocation : String in method public triggerSavepoint(timestamp long, targetLocation String) : CompletableFuture<CompletedCheckpoint> in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Rename Parameter savepointPath : String to savepointPointer : String in method public restoreSavepoint(savepointPointer String, allowNonRestored boolean, tasks Map<JobVertexID,ExecutionJobVertex>, userClassLoader ClassLoader) : boolean in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Rename Parameter targetDirectory : String to externalSavepointLocation : String in method package triggerCheckpoint(timestamp long, props CheckpointProperties, externalSavepointLocation String, isPeriodic boolean) : CheckpointTriggerResult in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Rename Parameter externalizedCheckpointSettings : ExternalizedCheckpointSettings to checkpointRetentionPolicy : CheckpointRetentionPolicy in method public CheckpointCoordinatorConfiguration(checkpointInterval long, checkpointTimeout long, minPauseBetweenCheckpoints long, maxConcurrentCheckpoints int, checkpointRetentionPolicy CheckpointRetentionPolicy, isExactlyOnce boolean) in class org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration |
From |
To |
|
Rename Parameter externalizedMetadata : StreamStateHandle to metadataHandle : StreamStateHandle in method public CompletedCheckpoint(job JobID, checkpointID long, timestamp long, completionTimestamp long, operatorStates Map<OperatorID,OperatorState>, masterHookStates Collection<MasterState>, props CheckpointProperties, metadataHandle StreamStateHandle, externalPointer String) in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint |
From |
To |
|
Rename Parameter externalizedSettings : ExternalizedCheckpointSettings to retentionPolicy : CheckpointRetentionPolicy in method public GraphAndSettings(graph AccessExecutionGraph, jobCheckpointingConfiguration CheckpointCoordinatorConfiguration, retentionPolicy CheckpointRetentionPolicy) in class org.apache.flink.runtime.rest.handler.legacy.checkpoints.CheckpointConfigHandlerTest.GraphAndSettings |
From |
To |
|
Rename Parameter targetDirectory : String to targetLocation : CheckpointStorageLocation in method public PendingCheckpoint(jobId JobID, checkpointId long, checkpointTimestamp long, verticesToConfirm Map<ExecutionAttemptID,ExecutionVertex>, props CheckpointProperties, targetLocation CheckpointStorageLocation, executor Executor) in class org.apache.flink.runtime.checkpoint.PendingCheckpoint |
From |
To |