4da40bcb9ea01cb0c5e6fd0d7472dc09397f648e
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 1 | ||
| Rename Variable e : Exception to t : Throwable in method public CheckpointCoordinator(job JobID, baseInterval long, checkpointTimeout long, minPauseBetweenCheckpoints long, maxConcurrentCheckpointAttempts int, numberKeyGroups int, tasksToTrigger ExecutionVertex[], tasksToWaitFor ExecutionVertex[], tasksToCommitTo ExecutionVertex[], userClassLoader ClassLoader, checkpointIDCounter CheckpointIDCounter, completedCheckpointStore CompletedCheckpointStore, savepointStore SavepointStore, statsTracker CheckpointStatsTracker) in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type e : Exception to t : Throwable in method public CheckpointCoordinator(job JobID, baseInterval long, checkpointTimeout long, minPauseBetweenCheckpoints long, maxConcurrentCheckpointAttempts int, numberKeyGroups int, tasksToTrigger ExecutionVertex[], tasksToWaitFor ExecutionVertex[], tasksToCommitTo ExecutionVertex[], userClassLoader ClassLoader, checkpointIDCounter CheckpointIDCounter, completedCheckpointStore CompletedCheckpointStore, savepointStore SavepointStore, statsTracker CheckpointStatsTracker) in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To |