c4b0e8f68c5c4bb2ba60b358df92ee5db1d857df
Files Diff
- Added: 1
- Removed: 3
- Renamed: 0
- Modified: 9
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public abortExpired() : void renamed to public abort(reason CheckpointFailureReason, cause Throwable) : void in class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type message : String to failureReason : CheckpointFailureReason in method public CheckpointException(failureReason CheckpointFailureReason, cause Throwable) in class org.apache.flink.runtime.checkpoint.CheckpointException | From | To | |
| Rename Variable | 3 | ||
| Rename Variable triggerResult : CheckpointTriggerResult to pendingCheckpoint : PendingCheckpoint in method private triggerSavepointInternal(timestamp long, checkpointProperties CheckpointProperties, advanceToEndOfEventTime boolean, targetLocation String) : CompletableFuture<CompletedCheckpoint> in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Rename Variable cause : Exception to exception : CheckpointException in method public abort(reason CheckpointFailureReason, cause Throwable) : void in class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To | |
| Rename Variable checkpointTriggerException : CheckpointTriggerException to checkpointException : CheckpointException in method private getJobModificationSavepoint(timeout Time) : CompletableFuture<String> in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Change Return Type | 1 | ||
| Change Return Type CheckpointTriggerResult to PendingCheckpoint in method public triggerCheckpoint(timestamp long, props CheckpointProperties, externalSavepointLocation String, isPeriodic boolean, advanceToEndOfTime boolean) : PendingCheckpoint in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.runtime.checkpoint.CheckpointDeclineReason renamed to org.apache.flink.runtime.checkpoint.CheckpointFailureReason | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type checkpointTriggerException : CheckpointTriggerException to checkpointException : CheckpointException in method private getJobModificationSavepoint(timeout Time) : CompletableFuture<String> in class org.apache.flink.runtime.jobmaster.JobMaster | From | To | |
| Change Variable Type triggerResult : CheckpointTriggerResult to pendingCheckpoint : PendingCheckpoint in method private triggerSavepointInternal(timestamp long, checkpointProperties CheckpointProperties, advanceToEndOfEventTime boolean, targetLocation String) : CompletableFuture<CompletedCheckpoint> in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Change Variable Type cause : Exception to exception : CheckpointException in method public abort(reason CheckpointFailureReason, cause Throwable) : void in class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter message : String to failureReason : CheckpointFailureReason in method public CheckpointException(failureReason CheckpointFailureReason, cause Throwable) in class org.apache.flink.runtime.checkpoint.CheckpointException | From | To |