579bc96446d598a2cfe8237b4ebd62d8c9df3483
Files Diff
- Added: 25
- Removed: 0
- Renamed: 0
- Modified: 33
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Inline Method | 1 | ||
| Move And Inline Method public setDuration(duration long) : void moved from class org.apache.flink.runtime.checkpoint.SubtaskState to class org.apache.flink.runtime.checkpoint.PendingCheckpoint & inlined to public acknowledgeTask(executionAttemptId ExecutionAttemptID, subtaskState SubtaskState, checkpointMetaData CheckpointMetaData) : TaskAcknowledgeResult | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type tracker : ArchivedCheckpointStatsTracker to tracker : CheckpointStatsTracker 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, tracker CheckpointStatsTracker) in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph | From | To | |
| Rename Variable | 1 | ||
| Rename Variable duration : long to ignoredDuration : long in method private deserializeSubtaskState(dis DataInputStream) : SubtaskState in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Serializer | From | To | |
| Extract Variable | 3 | ||
| Extract Variable cause : Exception in method public abortExpired() : void from class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To | |
| Extract Variable failure : Exception in method public abortError(cause Throwable) : void from class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To | |
| Extract Variable cause : Exception in method public abortDeclined() : void from class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type tracker : ArchivedCheckpointStatsTracker to tracker : CheckpointStatsTracker in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public setCheckpointStatsTracker(statsTracker CheckpointStatsTracker) : void extracted from public enableSnapshotCheckpointing(interval long, checkpointTimeout long, minPauseBetweenCheckpoints long, maxConcurrentCheckpoints int, externalizeSettings ExternalizedCheckpointSettings, verticesToTrigger List<ExecutionJobVertex>, verticesToWaitFor List<ExecutionJobVertex>, verticesToCommitTo List<ExecutionJobVertex>, checkpointIDCounter CheckpointIDCounter, checkpointStore CompletedCheckpointStore, checkpointDir String, statsTracker CheckpointStatsTracker) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph & moved to class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To |