73c73e92750ab8fb068d0a3cb37afcb642084fc0
Files Diff
- Added: 39
- Removed: 6
- Renamed: 0
- Modified: 32
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public abstract testProgram(jobManagerPort int, coordinateDir File) : void renamed to public abstract testTaskManagerFailure(jobManagerPort int, coordinateDir File) : void in class org.apache.flink.test.recovery.AbstractTaskManagerProcessFailureRecoveryTest | From | To | |
| Rename Method public testProgram(jobManagerPort int, coordinateDir File) : void renamed to public testTaskManagerFailure(jobManagerPort int, coordinateDir File) : void in class org.apache.flink.test.recovery.TaskManagerProcessFailureStreamingRecoveryITCase | From | To | |
| Rename Method public testProgram(jobManagerPort int, coordinateDir File) : void renamed to public testTaskManagerFailure(jobManagerPort int, coordinateDir File) : void in class org.apache.flink.test.recovery.TaskManagerProcessFailureBatchRecoveryITCase | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type states : List<StateForTask> to states : ArrayList<StateForTask> in method public CompletedCheckpoint(job JobID, checkpointID long, timestamp long, states ArrayList<StateForTask>) in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint | From | To | |
| Change Return Type | 2 | ||
| Change Return Type SuccessfulCheckpoint to CompletedCheckpoint in method public toCompletedCheckpoint() : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To | |
| Change Return Type List<SuccessfulCheckpoint> to List<CompletedCheckpoint> in method public getSuccessfulCheckpoints() : List<CompletedCheckpoint> in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Rename Class | 5 | ||
| Rename Class org.apache.flink.test.recovery.AbstractProcessFailureRecoveryTest renamed to org.apache.flink.test.recovery.AbstractTaskManagerProcessFailureRecoveryTest | From | To | |
| Rename Class org.apache.flink.runtime.checkpoint.SuccessfulCheckpoint renamed to org.apache.flink.runtime.checkpoint.CompletedCheckpoint | From | To | |
| Rename Class org.apache.flink.test.checkpointing.StateCheckpoinedITCase renamed to org.apache.flink.test.checkpointing.StateCheckpointedITCase | From | To | |
| Rename Class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase renamed to org.apache.flink.test.recovery.TaskManagerProcessFailureStreamingRecoveryITCase | From | To | |
| Rename Class org.apache.flink.test.recovery.ProcessFailureBatchRecoveryITCase renamed to org.apache.flink.test.recovery.TaskManagerProcessFailureBatchRecoveryITCase | From | To | |
| Move Class | 1 | ||
| Move Class org.apache.flink.test.recovery.AbstractProcessFailureRecoveryTest.PipeForwarder moved to org.apache.flink.runtime.testutils.CommonTestUtils.PipeForwarder | From | To | |
| Change Variable Type | 9 | ||
| Change Variable Type completed : SuccessfulCheckpoint to completed : CompletedCheckpoint in method public toCompletedCheckpoint() : CompletedCheckpoint in class org.apache.flink.runtime.checkpoint.PendingCheckpoint | From | To | |
| Change Variable Type completed : SuccessfulCheckpoint to completed : CompletedCheckpoint in method public receiveAcknowledgeMessage(message AcknowledgeCheckpoint) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To | |
| Change Variable Type sc1 : SuccessfulCheckpoint to sc1 : CompletedCheckpoint in method public testMultipleConcurrentCheckpoints() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest | From | To | |
| Change Variable Type success : SuccessfulCheckpoint to success : CompletedCheckpoint in method public testSuccessfulCheckpointSubsumesUnsuccessful() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest | From | To | |
| Change Variable Type scs : List<SuccessfulCheckpoint> to scs : List<CompletedCheckpoint> in method public testSuccessfulCheckpointSubsumesUnsuccessful() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest | From | To | |
| Change Variable Type successNew : SuccessfulCheckpoint to successNew : CompletedCheckpoint in method public testTriggerAndConfirmSimpleCheckpoint() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest | From | To | |
| Change Variable Type sc2 : SuccessfulCheckpoint to sc2 : CompletedCheckpoint in method public testMultipleConcurrentCheckpoints() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest | From | To | |
| Change Variable Type scs : List<SuccessfulCheckpoint> to scs : List<CompletedCheckpoint> in method public testMultipleConcurrentCheckpoints() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest | From | To | |
| Change Variable Type success : SuccessfulCheckpoint to success : CompletedCheckpoint in method public testTriggerAndConfirmSimpleCheckpoint() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest | From | To | |
| Extract Method | 1 | ||
| Extract Method public createLeaderElectionService(client CuratorFramework, configuration Configuration) : ZooKeeperLeaderElectionService extracted from public createLeaderElectionService(configuration Configuration) : ZooKeeperLeaderElectionService in class org.apache.flink.runtime.util.ZooKeeperUtils | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type states : List<StateForTask> to states : ArrayList<StateForTask> in class org.apache.flink.runtime.checkpoint.CompletedCheckpoint | From | To | |
| Change Attribute Type checkpointIdCounter : AtomicLong to checkpointIdCounter : CheckpointIDCounter in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator | From | To |