8c57e5aed871b42d51e6218620ce7bd7991338c0
Files Diff
- Added: 2
- Removed: 8
- Renamed: 0
- Modified: 39
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public checkpointingIsEnabledIfIntervalIsPositive() : void renamed to public checkpointingIsEnabledIfIntervalIsqAndLegal() : void in class org.apache.flink.runtime.jobgraph.JobGraphTest | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type cause : CheckpointDeclineException to cause : CheckpointException in method private notifyAbort(checkpointId long, cause CheckpointException) : void in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Merge Parameter | 2 | ||
| Merge Parameter [interval : long, checkpointTimeout : long, minPauseBetweenCheckpoints : long, maxConcurrentCheckpoints : int, retentionPolicy : CheckpointRetentionPolicy] to chkConfig : CheckpointCoordinatorConfiguration in method public enableCheckpointing(chkConfig CheckpointCoordinatorConfiguration, verticesToTrigger List<ExecutionJobVertex>, verticesToWaitFor List<ExecutionJobVertex>, verticesToCommitTo List<ExecutionJobVertex>, masterHooks List<MasterTriggerRestoreHook<?>>, checkpointIDCounter CheckpointIDCounter, checkpointStore CompletedCheckpointStore, checkpointStateBackend StateBackend, statsTracker CheckpointStatsTracker) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
| Merge Parameter [checkpointTimeout : long, maxConcurrentCheckpointAttempts : int, isPreferCheckpointForRecovery : boolean, retentionPolicy : CheckpointRetentionPolicy, minPauseBetweenCheckpoints : long, baseInterval : long] to chkConfig : CheckpointCoordinatorConfiguration in method public CheckpointCoordinator(job JobID, chkConfig CheckpointCoordinatorConfiguration, tasksToTrigger ExecutionVertex[], tasksToWaitFor ExecutionVertex[], tasksToCommitTo ExecutionVertex[], checkpointIDCounter CheckpointIDCounter, completedCheckpointStore CompletedCheckpointStore, checkpointStateBackend StateBackend, executor Executor, sharedStateRegistryFactory SharedStateRegistryFactory, failureManager CheckpointFailureManager) in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Parameterize Variable | 3 | ||
| Parameterize Variable t : Throwable to cause : Throwable in method private failPendingCheckpoint(pendingCheckpoint PendingCheckpoint, reason CheckpointFailureReason, cause Throwable) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Parameterize Variable e1 : Exception to cause : Throwable in method private failPendingCheckpoint(pendingCheckpoint PendingCheckpoint, reason CheckpointFailureReason, cause Throwable) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Parameterize Variable checkpoint : PendingCheckpoint to pendingCheckpoint : PendingCheckpoint in method private failPendingCheckpoint(pendingCheckpoint PendingCheckpoint, reason CheckpointFailureReason, cause Throwable) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type e1 : Exception to cause : Throwable in method private failPendingCheckpoint(pendingCheckpoint PendingCheckpoint, reason CheckpointFailureReason, cause Throwable) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Extract Method | 3 | ||
| Extract Method private failPendingCheckpoint(pendingCheckpoint PendingCheckpoint, reason CheckpointFailureReason, cause Throwable) : void extracted from public triggerCheckpoint(timestamp long, props CheckpointProperties, externalSavepointLocation String, isPeriodic boolean, advanceToEndOfTime boolean) : PendingCheckpoint in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Extract Method private failPendingCheckpoint(pendingCheckpoint PendingCheckpoint, reason CheckpointFailureReason, cause Throwable) : void extracted from private completePendingCheckpoint(pendingCheckpoint PendingCheckpoint) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Extract Method private checkConnectionState() : void extracted from public getAndIncrement() : long in class org.apache.flink.runtime.checkpoint.ZooKeeperCheckpointIDCounter | From | To |