dc8e27fb07ec8593037ce0205b5ecb4a5bc16a40
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Extract Variable | 1 | ||
Extract Variable snapshotFailMessage : String in method public snapshotState(checkpointId long, timestamp long, checkpointOptions CheckpointOptions, factory CheckpointStreamFactory) : OperatorSnapshotFutures from class org.apache.flink.streaming.api.operators.AbstractStreamOperator | From | To | |
Inline Variable | 1 | ||
Inline Variable failure : Exception in method public abortError(cause Throwable) : void from class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To | |
Extract Method | 2 | ||
Extract Method private abortWithCause(cause Exception) : void extracted from public abortDeclined() : void in class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To | |
Extract Method private abortWithCause(cause Exception) : void extracted from public abortError(cause Throwable) : void in class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To |