|
Change Parameter Type jobSnapshottingSettings : JobSnapshottingSettings to jobCheckpointingSettings : JobCheckpointingSettings in method public ArchivedExecutionGraph(jobID JobID, jobName String, tasks Map<JobVertexID,ArchivedExecutionJobVertex>, verticesInCreationOrder List<ArchivedExecutionJobVertex>, stateTimestamps long[], state JobStatus, failureCause String, jsonPlan String, archivedUserAccumulators StringifiedAccumulatorResult[], serializedUserAccumulators Map<String,SerializedValue<Object>>, executionConfig ArchivedExecutionConfig, isStoppable boolean, jobCheckpointingSettings JobCheckpointingSettings, checkpointStatsSnapshot CheckpointStatsSnapshot) in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph |
From |
To |
|
Change Parameter Type settings : JobSnapshottingSettings to settings : JobCheckpointingSettings in method public setSnapshotSettings(settings JobCheckpointingSettings) : void in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |
|
Change Parameter Type snapshottingSettings : JobSnapshottingSettings to snapshottingSettings : JobCheckpointingSettings in method public GraphAndSettings(graph AccessExecutionGraph, snapshottingSettings JobCheckpointingSettings, externalizedSettings ExternalizedCheckpointSettings) in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointConfigHandlerTest.GraphAndSettings |
From |
To |
|
Change Parameter Type jobSnapshottingSettings : JobSnapshottingSettings to jobCheckpointingSettings : JobCheckpointingSettings in method public CheckpointStatsTracker(numRememberedCheckpoints int, jobVertices List<ExecutionJobVertex>, jobCheckpointingSettings JobCheckpointingSettings, metricGroup MetricGroup) in class org.apache.flink.runtime.checkpoint.CheckpointStatsTracker |
From |
To |
|
Change Variable Type settings : JobSnapshottingSettings to settings : JobCheckpointingSettings in method public testSimpleConfig() : void in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointConfigHandlerTest |
From |
To |
|
Change Variable Type newSnapshottingSettings : JobSnapshottingSettings to newSnapshottingSettings : JobCheckpointingSettings in method public testSavepointRestoreSettings() : void in class org.apache.flink.runtime.jobmanager.JobManagerTest |
From |
To |
|
Change Variable Type snapshottingSettings : JobSnapshottingSettings to snapshottingSettings : JobCheckpointingSettings in method public testCancelWithSavepoint() : void in class org.apache.flink.runtime.jobmanager.JobManagerTest |
From |
To |
|
Change Variable Type snapshottingSettings : JobSnapshottingSettings to snapshottingSettings : JobCheckpointingSettings in method public testDisabledCheckpointing() : void in class org.apache.flink.streaming.api.graph.StreamingJobGraphGeneratorTest |
From |
To |
|
Change Variable Type snapshotSettings : JobSnapshottingSettings to snapshotSettings : JobCheckpointingSettings in method public buildGraph(prior ExecutionGraph, jobGraph JobGraph, jobManagerConfig Configuration, futureExecutor ScheduledExecutorService, ioExecutor Executor, slotProvider SlotProvider, classLoader ClassLoader, recoveryFactory CheckpointRecoveryFactory, timeout Time, restartStrategy RestartStrategy, metrics MetricGroup, parallelismForAutoMax int, log Logger) : ExecutionGraph in class org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder |
From |
To |
|
Change Variable Type settings : JobSnapshottingSettings to settings : JobCheckpointingSettings in method public testIsJavaSerializable() : void in class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettingsTest |
From |
To |
|
Change Variable Type snapshottingSettings : JobSnapshottingSettings to snapshottingSettings : JobCheckpointingSettings in method public testSavepointRestoreSettings() : void in class org.apache.flink.runtime.jobmanager.JobManagerTest |
From |
To |
|
Change Variable Type settings : JobSnapshottingSettings to settings : JobCheckpointingSettings in method public testArchiver() : void in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointConfigHandlerTest |
From |
To |
|
Change Variable Type settings : JobSnapshottingSettings to settings : JobCheckpointingSettings in method private configureCheckpointing() : void in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type snapshottingSettings : JobSnapshottingSettings to snapshottingSettings : JobCheckpointingSettings in method public testGetSnapshottingSettings() : void in class org.apache.flink.runtime.checkpoint.CheckpointStatsTrackerTest |
From |
To |
|
Change Variable Type snapshottingSettings : JobSnapshottingSettings to snapshottingSettings : JobCheckpointingSettings in method public testCancelWithSavepointNoDirectoriesConfigured() : void in class org.apache.flink.runtime.jobmanager.JobManagerTest |
From |
To |
|
Change Variable Type settings : JobSnapshottingSettings to settings : JobCheckpointingSettings in method private createCheckpointConfigJson(graph AccessExecutionGraph) : String in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointConfigHandler |
From |
To |
|
Change Variable Type settings : JobSnapshottingSettings to settings : JobCheckpointingSettings in method private createGraphAndSettings(externalized boolean, exactlyOnce boolean) : GraphAndSettings in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointConfigHandlerTest |
From |
To |
|
Change Variable Type copy : JobSnapshottingSettings to copy : JobCheckpointingSettings in method public testIsJavaSerializable() : void in class org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettingsTest |
From |
To |
|
Change Variable Type snapshottingSettings : JobSnapshottingSettings to snapshottingSettings : JobCheckpointingSettings in method public testSavepointWithDeactivatedPeriodicCheckpointing() : void in class org.apache.flink.runtime.jobmanager.JobManagerTest |
From |
To |
|
Rename Parameter jobSnapshottingSettings : JobSnapshottingSettings to jobCheckpointingSettings : JobCheckpointingSettings in method public CheckpointStatsTracker(numRememberedCheckpoints int, jobVertices List<ExecutionJobVertex>, jobCheckpointingSettings JobCheckpointingSettings, metricGroup MetricGroup) in class org.apache.flink.runtime.checkpoint.CheckpointStatsTracker |
From |
To |
|
Rename Parameter jobSnapshottingSettings : JobSnapshottingSettings to jobCheckpointingSettings : JobCheckpointingSettings in method public ArchivedExecutionGraph(jobID JobID, jobName String, tasks Map<JobVertexID,ArchivedExecutionJobVertex>, verticesInCreationOrder List<ArchivedExecutionJobVertex>, stateTimestamps long[], state JobStatus, failureCause String, jsonPlan String, archivedUserAccumulators StringifiedAccumulatorResult[], serializedUserAccumulators Map<String,SerializedValue<Object>>, executionConfig ArchivedExecutionConfig, isStoppable boolean, jobCheckpointingSettings JobCheckpointingSettings, checkpointStatsSnapshot CheckpointStatsSnapshot) in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph |
From |
To |