ddd6a99a95b56c52ea5b5153b7270b578f5479bc
Files Diff
- Added: 5
- Removed: 1
- Renamed: 0
- Modified: 129
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Inline Method | 1 | ||
| Move And Inline Method public stop() : void moved from class org.apache.flink.runtime.checkpoint.ZooKeeperCheckpointRecoveryFactory to class org.apache.flink.test.javaApiOperators.RemoteEnvironmentITCase & inlined to public tearDownCluster() : void | From | To | |
| Change Parameter Type | 5 | ||
| Change Parameter Type leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public submitJob(actorSystem ActorSystem, config Configuration, highAvailabilityServices HighAvailabilityServices, jobGraph JobGraph, timeout FiniteDuration, sysoutLogUpdates boolean, classLoader ClassLoader) : JobListeningContext in class org.apache.flink.runtime.client.JobClient | From | To | |
| Change Parameter Type leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public submitJobAndWait(actorSystem ActorSystem, config Configuration, highAvailabilityServices HighAvailabilityServices, jobGraph JobGraph, timeout FiniteDuration, sysoutLogUpdates boolean, classLoader ClassLoader) : JobExecutionResult in class org.apache.flink.runtime.client.JobClient | From | To | |
| Change Parameter Type leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public attachToRunningJob(jobID JobID, jobManagerGateWay ActorGateway, configuration Configuration, actorSystem ActorSystem, highAvailabilityServices HighAvailabilityServices, timeout FiniteDuration, sysoutLogUpdates boolean) : JobListeningContext in class org.apache.flink.runtime.client.JobClient | From | To | |
| Change Parameter Type jmPort : int to env : ExecutionEnvironment in method private runConnectedComponents(env ExecutionEnvironment) : void in class org.apache.flink.test.misc.SuccessAfterNetworkBuffersFailureITCase | From | To | |
| Change Parameter Type jmPort : int to env : ExecutionEnvironment in method private runKMeans(env ExecutionEnvironment) : void in class org.apache.flink.test.misc.SuccessAfterNetworkBuffersFailureITCase | From | To | |
| Rename Variable | 4 | ||
| Rename Variable leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public testMetricRegistryLifeCycle() : void in class org.apache.flink.runtime.metrics.TaskManagerMetricsTest | From | To | |
| Rename Variable me : ActorGateway to forwardingActor : ActorGateway in method public testClusterShutdownWithoutResourceManager() : void in class org.apache.flink.runtime.clusterframework.ClusterShutdownITCase | From | To | |
| Rename Variable me : ActorGateway to forwardingActor : ActorGateway in method public testClusterShutdownWithResourceManager() : void in class org.apache.flink.runtime.clusterframework.ClusterShutdownITCase | From | To | |
| Rename Variable me : ActorGateway to forwardingActor : ActorGateway in method public testResourceManagerTaskManagerRegistration() : void in class org.apache.flink.runtime.clusterframework.ResourceManagerITCase | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private config : Configuration from class org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalTest.FindConnectingAddress to private config : Configuration from class org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalTest | From | To | |
| Extract Attribute | 5 | ||
| Extract Attribute protected NUM_TMS : int in class org.apache.flink.streaming.connectors.kafka.KafkaShortRetentionTestBase | From | To | |
| Extract Attribute private PARALLELISM : int in class org.apache.flink.test.misc.SuccessAfterNetworkBuffersFailureITCase | From | To | |
| Extract Attribute protected TM_SLOTS : int in class org.apache.flink.streaming.connectors.kafka.KafkaShortRetentionTestBase | From | To | |
| Extract Attribute protected NUM_TMS : int in class org.apache.flink.streaming.connectors.kafka.KafkaTestBase | From | To | |
| Extract Attribute protected TM_SLOTS : int in class org.apache.flink.streaming.connectors.kafka.KafkaTestBase | From | To | |
| Replace Variable With Attribute | 4 | ||
| Replace Variable With Attribute leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public retrieveJob(jobID JobID) : JobExecutionResult in class org.apache.flink.client.program.ClusterClient | From | To | |
| Replace Variable With Attribute leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public run(jobGraph JobGraph, classLoader ClassLoader) : JobExecutionResult in class org.apache.flink.client.program.ClusterClient | From | To | |
| Replace Variable With Attribute leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public connectToJob(jobID JobID) : JobListeningContext in class org.apache.flink.client.program.ClusterClient | From | To | |
| Replace Variable With Attribute config : Configuration to configuration : Configuration in method public setupCluster() : void in class org.apache.flink.test.javaApiOperators.RemoteEnvironmentITCase | From | To | |
| Rename Attribute | 3 | ||
| Rename Attribute config : Configuration to leaderRetrievalService : LeaderRetrievalService in class org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalTest.FindConnectingAddress | From | To | |
| Rename Attribute executor : LocalFlinkMiniCluster to miniCluster : LocalFlinkMiniCluster in class org.apache.flink.streaming.util.TestStreamEnvironment | From | To | |
| Rename Attribute executor : LocalFlinkMiniCluster to miniCluster : LocalFlinkMiniCluster in class org.apache.flink.test.util.TestEnvironment | From | To | |
| Extract Variable | 7 | ||
| Extract Variable jobManagerHostname : String in method public testReapProcessOnFailure() : void from class org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTestBase | From | To | |
| Extract Variable configuration : Configuration in method public before() : void from class org.apache.flink.test.clients.examples.JobRetrievalITCase | From | To | |
| Extract Variable parallelism : int in method public testThis() : void from class org.apache.flink.test.recovery.FastFailuresITCase | From | To | |
| Extract Variable config : Configuration in method public testReapProcessOnFailure() : void from class org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTestBase | From | To | |
| Extract Variable parallelism : int in method public testExternalProgram() : void from class org.apache.flink.api.avro.AvroExternalJarProgramITCase | From | To | |
| Extract Variable finalTaskManager : ActorRef in method public testComponentsStartupShutdown() : void from class org.apache.flink.runtime.taskmanager.TaskManagerComponentsStartupShutdownTest | From | To | |
| Extract Variable configuration : Configuration in method public setupCluster() : void from class org.apache.flink.test.state.operator.restore.AbstractOperatorRestoreTestBase | From | To | |
| Change Variable Type | 5 | ||
| Change Variable Type leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public connectToJob(jobID JobID) : JobListeningContext in class org.apache.flink.client.program.ClusterClient | From | To | |
| Change Variable Type leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public testMetricRegistryLifeCycle() : void in class org.apache.flink.runtime.metrics.TaskManagerMetricsTest | From | To | |
| Change Variable Type leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public retrieveJob(jobID JobID) : JobExecutionResult in class org.apache.flink.client.program.ClusterClient | From | To | |
| Change Variable Type leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public run(jobGraph JobGraph, classLoader ClassLoader) : JobExecutionResult in class org.apache.flink.client.program.ClusterClient | From | To | |
| Change Variable Type classpath : String to classpath : URL in method public testJobsWithCustomClassLoader() : void in class org.apache.flink.test.classloading.ClassLoaderITCase | From | To | |
| Extract Method | 1 | ||
| Extract Method public setAsContext(cluster LocalFlinkMiniCluster, parallelism int, jarFiles Collection<Path>, classpaths Collection<URL>) : void extracted from public setAsContext(cluster LocalFlinkMiniCluster, parallelism int) : void in class org.apache.flink.streaming.util.TestStreamEnvironment | From | To | |
| Change Attribute Type | 4 | ||
| Change Attribute Type config : Configuration to leaderRetrievalService : LeaderRetrievalService in class org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalTest.FindConnectingAddress | From | To | |
| Change Attribute Type cluster : LeaderElectionRetrievalTestingCluster to cluster : TestingCluster in class org.apache.flink.runtime.leaderelection.LeaderChangeJobRecoveryTest | From | To | |
| Change Attribute Type cluster : LeaderElectionRetrievalTestingCluster to cluster : TestingCluster in class org.apache.flink.runtime.leaderelection.LeaderChangeStateCleanupTest | From | To | |
| Change Attribute Type cluster : LocalFlinkMiniCluster to cluster : StandaloneMiniCluster in class org.apache.flink.test.javaApiOperators.RemoteEnvironmentITCase | From | To | |
| Rename Parameter | 6 | ||
| Rename Parameter leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public attachToRunningJob(jobID JobID, jobManagerGateWay ActorGateway, configuration Configuration, actorSystem ActorSystem, highAvailabilityServices HighAvailabilityServices, timeout FiniteDuration, sysoutLogUpdates boolean) : JobListeningContext in class org.apache.flink.runtime.client.JobClient | From | To | |
| Rename Parameter executor : LocalFlinkMiniCluster to miniCluster : LocalFlinkMiniCluster in method public TestStreamEnvironment(miniCluster LocalFlinkMiniCluster, parallelism int) in class org.apache.flink.streaming.util.TestStreamEnvironment | From | To | |
| Rename Parameter leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public submitJob(actorSystem ActorSystem, config Configuration, highAvailabilityServices HighAvailabilityServices, jobGraph JobGraph, timeout FiniteDuration, sysoutLogUpdates boolean, classLoader ClassLoader) : JobListeningContext in class org.apache.flink.runtime.client.JobClient | From | To | |
| Rename Parameter leaderRetrievalService : LeaderRetrievalService to highAvailabilityServices : HighAvailabilityServices in method public submitJobAndWait(actorSystem ActorSystem, config Configuration, highAvailabilityServices HighAvailabilityServices, jobGraph JobGraph, timeout FiniteDuration, sysoutLogUpdates boolean, classLoader ClassLoader) : JobExecutionResult in class org.apache.flink.runtime.client.JobClient | From | To | |
| Rename Parameter jmPort : int to env : ExecutionEnvironment in method private runConnectedComponents(env ExecutionEnvironment) : void in class org.apache.flink.test.misc.SuccessAfterNetworkBuffersFailureITCase | From | To | |
| Rename Parameter jmPort : int to env : ExecutionEnvironment in method private runKMeans(env ExecutionEnvironment) : void in class org.apache.flink.test.misc.SuccessAfterNetworkBuffersFailureITCase | From | To |