flink 4ca7df592538edb6fd69159c7b955673ed3af820

4ca7df592538edb6fd69159c7b955673ed3af820

Files Diff

Added: 2
Removed: 0
Renamed: 0
Modified: 5

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Rename Method	3
Rename Method public runCheckpointedProgram() : void renamed to public postSubmit() : void in class org.apache.flink.test.checkpointing.StateCheckpoinedITCase	From	To
Rename Method public runCheckpointedProgram() : void renamed to public postSubmit() : void in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase	From	To
Rename Method public runCheckpointedProgram() : void renamed to public postSubmit() : void in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase	From	To
Pull Up Method	9
Pull Up Method public shutdownCluster() : void from class org.apache.flink.test.checkpointing.StateCheckpoinedITCase to public shutdownCluster() : void from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Method public startCluster() : void from class org.apache.flink.test.checkpointing.StreamCheckpointingITCase to public startCluster() : void from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Method public startCluster() : void from class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase to public startCluster() : void from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Method public shutdownCluster() : void from class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase to public shutdownCluster() : void from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Method public shutdownCluster() : void from class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase to public shutdownCluster() : void from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Method public shutdownCluster() : void from class org.apache.flink.test.checkpointing.StreamCheckpointingITCase to public shutdownCluster() : void from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Method public startCluster() : void from class org.apache.flink.test.checkpointing.StateCheckpoinedITCase to public startCluster() : void from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Method public runCheckpointedProgram() : void from class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase to public runCheckpointedProgram() : void from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Method public startCluster() : void from class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase to public startCluster() : void from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute	16
Pull Up Attribute private cluster : ForkableFlinkMiniCluster from class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase to private cluster : ForkableFlinkMiniCluster from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private PARALLELISM : int from class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase to protected PARALLELISM : int from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private NUM_TASK_MANAGERS : int from class org.apache.flink.test.checkpointing.StateCheckpoinedITCase to protected NUM_TASK_MANAGERS : int from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private PARALLELISM : int from class org.apache.flink.test.checkpointing.StateCheckpoinedITCase to protected PARALLELISM : int from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private PARALLELISM : int from class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase to protected PARALLELISM : int from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private NUM_TASK_MANAGERS : int from class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase to protected NUM_TASK_MANAGERS : int from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private NUM_TASK_MANAGERS : int from class org.apache.flink.test.checkpointing.StreamCheckpointingITCase to protected NUM_TASK_MANAGERS : int from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private cluster : ForkableFlinkMiniCluster from class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase to private cluster : ForkableFlinkMiniCluster from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private NUM_TASK_SLOTS : int from class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase to protected NUM_TASK_SLOTS : int from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private NUM_TASK_SLOTS : int from class org.apache.flink.test.checkpointing.StateCheckpoinedITCase to protected NUM_TASK_SLOTS : int from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private PARALLELISM : int from class org.apache.flink.test.checkpointing.StreamCheckpointingITCase to protected PARALLELISM : int from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private NUM_TASK_SLOTS : int from class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase to protected NUM_TASK_SLOTS : int from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private NUM_TASK_SLOTS : int from class org.apache.flink.test.checkpointing.StreamCheckpointingITCase to protected NUM_TASK_SLOTS : int from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private NUM_TASK_MANAGERS : int from class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase to protected NUM_TASK_MANAGERS : int from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private cluster : ForkableFlinkMiniCluster from class org.apache.flink.test.checkpointing.StreamCheckpointingITCase to private cluster : ForkableFlinkMiniCluster from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Pull Up Attribute private cluster : ForkableFlinkMiniCluster from class org.apache.flink.test.checkpointing.StateCheckpoinedITCase to private cluster : ForkableFlinkMiniCluster from class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Move Class	1
Move Class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.PrefixCount moved to org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase.PrefixCount	From	To
Extract Superclass	1
Extract Superclass org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase from classes [org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase, org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase, org.apache.flink.test.checkpointing.StateCheckpoinedITCase, org.apache.flink.test.checkpointing.StreamCheckpointingITCase]	From	To
Change Attribute Type	1
Change Attribute Type count : OperatorState<Long> to count : long in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StatefulCounterFunction	From	To

4ca7df592538edb6fd69159c7b955673ed3af820

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: