0231460259b410f42dd4933cb3ae993450bf1694
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 3
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Variable | 2 | ||
Rename Variable clusterClient : StandaloneClusterClient to client : ClusterClient<?> in method protected restoreAndExecute(env StreamExecutionEnvironment, savepointPath String, expectedAccumulators Tuple2<String,Integer>...) : void in class org.apache.flink.test.checkpointing.utils.SavepointMigrationTestBase | From | To | |
Rename Variable clusterClient : StandaloneClusterClient to client : ClusterClient<?> in method protected executeAndSavepoint(env StreamExecutionEnvironment, savepointPath String, expectedAccumulators Tuple2<String,Integer>...) : void in class org.apache.flink.test.checkpointing.utils.SavepointMigrationTestBase | From | To | |
Change Variable Type | 2 | ||
Change Variable Type clusterClient : StandaloneClusterClient to client : ClusterClient<?> in method protected restoreAndExecute(env StreamExecutionEnvironment, savepointPath String, expectedAccumulators Tuple2<String,Integer>...) : void in class org.apache.flink.test.checkpointing.utils.SavepointMigrationTestBase | From | To | |
Change Variable Type clusterClient : StandaloneClusterClient to client : ClusterClient<?> in method protected executeAndSavepoint(env StreamExecutionEnvironment, savepointPath String, expectedAccumulators Tuple2<String,Integer>...) : void in class org.apache.flink.test.checkpointing.utils.SavepointMigrationTestBase | From | To |