flink b9de4ed37ffa68ef50dc6d6b3819afcc00d1d029

b9de4ed37ffa68ef50dc6d6b3819afcc00d1d029

Files Diff

Added: 38
Removed: 8
Renamed: 0
Modified: 148

Link to commit

Dependency Action
Added
	org.apache.curator:curator-test:2.8.0

Refactorings reported:

Refactoring Name	Occurences
Rename Method	2
Rename Method private parseJobManagerAddress(hostAndPort String) : InetSocketAddress renamed to private parseHostPortAddress(hostAndPort String) : InetSocketAddress in class org.apache.flink.client.CliFrontend	From	To
Rename Method public shutdownCluster() : void renamed to public stopCluster() : void in class org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase	From	To
Change Parameter Type	15
Change Parameter Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in method public registerTaskManager(taskManager ActorRef, connectionInfo InstanceConnectionInfo, resources HardwareDescription, numberOfSlots int, leaderSessionID UUID) : InstanceID in class org.apache.flink.runtime.instance.InstanceManager	From	To
Change Parameter Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in method public JobClientActor(jobManager ActorRef, logger Logger, sysoutUpdates boolean, leaderSessionID UUID) in class org.apache.flink.runtime.client.JobClientActor	From	To
Change Parameter Type source : ActorGateway to retriever : JobManagerArchiveRetriever in method public ExecutionGraphHolder(retriever JobManagerArchiveRetriever, timeout FiniteDuration) in class org.apache.flink.runtime.webmonitor.ExecutionGraphHolder	From	To
Change Parameter Type target : ActorGateway to retriever : JobManagerArchiveRetriever in method public RequestJobIdsHandler(retriever JobManagerArchiveRetriever) in class org.apache.flink.runtime.webmonitor.handlers.RequestJobIdsHandler	From	To
Change Parameter Type jobManager : ActorRef to jobManager : ActorGateway in method private awaitRunning(jobManager ActorGateway, jobId JobID, timeout FiniteDuration) : void in class org.apache.flink.runtime.taskmanager.TaskCancelTest	From	To
Change Parameter Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in method public AkkaActorGateway(actor ActorRef, leaderSessionID UUID) in class org.apache.flink.runtime.instance.AkkaActorGateway	From	To
Change Parameter Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in method public enableSnapshotCheckpointing(interval long, checkpointTimeout long, verticesToTrigger List<ExecutionJobVertex>, verticesToWaitFor List<ExecutionJobVertex>, verticesToCommitTo List<ExecutionJobVertex>, actorSystem ActorSystem, leaderSessionID UUID) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph	From	To
Change Parameter Type source : ActorGateway to retriever : JobManagerArchiveRetriever in method public ExecutionGraphHolder(retriever JobManagerArchiveRetriever) in class org.apache.flink.runtime.webmonitor.ExecutionGraphHolder	From	To
Change Parameter Type target : ActorGateway to retriever : JobManagerArchiveRetriever in method public RequestJobIdsHandler(retriever JobManagerArchiveRetriever, timeout FiniteDuration) in class org.apache.flink.runtime.webmonitor.handlers.RequestJobIdsHandler	From	To
Change Parameter Type jobManager : ActorGateway to retriever : JobManagerArchiveRetriever in method public RequestOverviewHandler(retriever JobManagerArchiveRetriever) in class org.apache.flink.runtime.webmonitor.handlers.RequestOverviewHandler	From	To
Change Parameter Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in method public CliJobManager(jobID JobID, leaderSessionID UUID) in class org.apache.flink.client.CliFrontendListCancelTest.CliJobManager	From	To
Change Parameter Type jobManager : ActorRef to jobManager : ActorGateway in method private awaitTermination(jobManager ActorGateway, jobId JobID, timeout FiniteDuration) : JobStatus in class org.apache.flink.runtime.taskmanager.TaskCancelTest	From	To
Change Parameter Type jobManager : ActorGateway to retriever : JobManagerArchiveRetriever in method public RequestOverviewHandler(retriever JobManagerArchiveRetriever, timeout FiniteDuration) in class org.apache.flink.runtime.webmonitor.handlers.RequestOverviewHandler	From	To
Change Parameter Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in method public PlainFlinkUntypedActor(leaderSessionID UUID) in class org.apache.flink.runtime.akka.FlinkUntypedActorTest.PlainFlinkUntypedActor	From	To
Change Parameter Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in method public createJobStatusListener(actorSystem ActorSystem, checkpointInterval long, leaderSessionID UUID) : ActorGateway in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator	From	To
Rename Variable	7
Rename Variable jm2Closure : ActorRef to fakeJM2GatewayClosure : ActorGateway in method public testTaskManagerResumesConnectAfterJobManagerFailure() : void in class org.apache.flink.runtime.taskmanager.TaskManagerRegistrationTest	From	To
Rename Variable jobManager : ActorGateway to jmGateway : ActorGateway in method public testCoordinatorShutsDownOnSuccess() : void in class org.apache.flink.runtime.checkpoint.CoordinatorShutdownTest	From	To
Rename Variable leaderSessionID : UUID to gateway : ActorGateway in method public testTaskManagerResumesConnectAfterJobManagerFailure() : void in class org.apache.flink.runtime.taskmanager.TaskManagerRegistrationTest	From	To
Rename Variable fakeJobManager2 : ActorRef to fakeJobManager2Gateway : ActorGateway in method public testTaskManagerResumesConnectAfterJobManagerFailure() : void in class org.apache.flink.runtime.taskmanager.TaskManagerRegistrationTest	From	To
Rename Variable jobManager : ActorGateway to jmGateway : ActorGateway in method public testCoordinatorShutsDownOnFailure() : void in class org.apache.flink.runtime.checkpoint.CoordinatorShutdownTest	From	To
Rename Variable jobManagerActorRef : ActorRef to leaderRetrievalService : LeaderRetrievalService in method public run(jobGraph JobGraph, wait boolean) : JobSubmissionResult in class org.apache.flink.client.program.Client	From	To
Rename Variable jobManagerName : String to taskManagerGateway : ActorGateway in method public testTaskManagerResumesConnectAfterJobManagerFailure() : void in class org.apache.flink.runtime.taskmanager.TaskManagerRegistrationTest	From	To
Change Return Type	12
Change Return Type Option<UUID> to UUID in method protected getLeaderSessionID() : UUID in class org.apache.flink.runtime.akka.FlinkUntypedActorTest.PlainFlinkUntypedActor	From	To
Change Return Type Option<UUID> to UUID in method protected getLeaderSessionID() : UUID in class org.apache.flink.runtime.taskmanager.TaskManagerTest.SimpleJobManager	From	To
Change Return Type Option<UUID> to UUID in method public leaderSessionID() : UUID in class org.apache.flink.runtime.instance.BaseTestingActorGateway	From	To
Change Return Type Option<UUID> to UUID in method protected getLeaderSessionID() : UUID in class org.apache.flink.client.program.ClientTest.FailureReturningActor	From	To
Change Return Type Option<UUID> to UUID in method public leaderSessionID() : UUID in class org.apache.flink.runtime.instance.AkkaActorGateway	From	To
Change Return Type Option<UUID> to UUID in method public leaderSessionID() : UUID in class org.apache.flink.runtime.instance.DummyActorGateway	From	To
Change Return Type Option<UUID> to UUID in method protected getLeaderSessionID() : UUID in class org.apache.flink.runtime.client.JobClientActor	From	To
Change Return Type Option<UUID> to UUID in method protected abstract getLeaderSessionID() : UUID in class org.apache.flink.runtime.akka.FlinkUntypedActor	From	To
Change Return Type Option<UUID> to UUID in method public getLeaderSessionID() : UUID in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorDeActivator	From	To
Change Return Type Option<UUID> to UUID in method protected getLeaderSessionID() : UUID in class org.apache.flink.client.CliFrontendListCancelTest.CliJobManager	From	To
Change Return Type Option<UUID> to UUID in method protected getLeaderSessionID() : UUID in class org.apache.flink.client.program.ClientTest.SuccessReturningActor	From	To
Change Return Type Option<UUID> to UUID in method public leaderSessionID() : UUID in class org.apache.flink.runtime.instance.ActorGateway	From	To
Rename Class	2
Rename Class org.apache.flink.runtime.taskmanager.TestManagerStartupTest renamed to org.apache.flink.runtime.taskmanager.TaskManagerStartupTest	From	To
Rename Class org.apache.flink.client.program.ClientHostnameResolutionTest renamed to org.apache.flink.client.program.LeaderRetrievalServiceHostnameResolutionTest	From	To
Replace Variable With Attribute	1
Replace Variable With Attribute jobManager : ActorGateway to retriever : JobManagerArchiveRetriever in method public WebRuntimeMonitor(config Configuration, leaderRetrievalService LeaderRetrievalService, actorSystem ActorSystem) in class org.apache.flink.runtime.webmonitor.WebRuntimeMonitor	From	To
Rename Attribute	6
Rename Attribute jobManager : ActorGateway to jmGateway : ActorGateway in class org.apache.flink.runtime.jobmanager.JobSubmitTest	From	To
Rename Attribute LOCAL_INSTANCE_MANAGER_START_WEBSERVER : String to LOCAL_START_WEBSERVER : String in class org.apache.flink.configuration.ConfigConstants	From	To
Rename Attribute expectedParallelim : int to expectedParallelism : int in class org.apache.flink.client.CliFrontendRunTest.RunTestingCliFrontend	From	To
Rename Attribute LOCAL_INSTANCE_MANAGER_NUMBER_TASK_MANAGER : String to LOCAL_NUMBER_TASK_MANAGER : String in class org.apache.flink.configuration.ConfigConstants	From	To
Rename Attribute jobManager : ActorGateway to retriever : JobManagerArchiveRetriever in class org.apache.flink.runtime.webmonitor.handlers.RequestOverviewHandler	From	To
Rename Attribute address : InetSocketAddress to configuration : Configuration in class org.apache.flink.client.RemoteExecutor	From	To
Extract Variable	1
Extract Variable config : Configuration in method public testGetExecutionPlan() : void from class org.apache.flink.client.program.ExecutionPlanCreationTest	From	To
Change Variable Type	12
Change Variable Type fakeJobManager2 : ActorRef to fakeJobManager2Gateway : ActorGateway in method public testTaskManagerResumesConnectAfterJobManagerFailure() : void in class org.apache.flink.runtime.taskmanager.TaskManagerRegistrationTest	From	To
Change Variable Type message : RegisterTaskManager to message : Object in method public testTaskManagerResumesConnectAfterJobManagerFailure() : void in class org.apache.flink.runtime.taskmanager.TaskManagerRegistrationTest	From	To
Change Variable Type jobManagerActorRef : ActorRef to leaderRetrievalService : LeaderRetrievalService in method public run(jobGraph JobGraph, wait boolean) : JobSubmissionResult in class org.apache.flink.client.program.Client	From	To
Change Variable Type actorMessage : TaskMessages.UpdateTaskExecutionState to actorMessage : UpdateTaskExecutionState in method private notifyObservers(newState ExecutionState, error Throwable) : void in class org.apache.flink.runtime.taskmanager.Task	From	To
Change Variable Type jobManagerName : String to taskManagerGateway : ActorGateway in method public testTaskManagerResumesConnectAfterJobManagerFailure() : void in class org.apache.flink.runtime.taskmanager.TaskManagerRegistrationTest	From	To
Change Variable Type jobManager : ActorGateway to retriever : JobManagerArchiveRetriever in method public WebRuntimeMonitor(config Configuration, leaderRetrievalService LeaderRetrievalService, actorSystem ActorSystem) in class org.apache.flink.runtime.webmonitor.WebRuntimeMonitor	From	To
Change Variable Type jm2Closure : ActorRef to fakeJM2GatewayClosure : ActorGateway in method public testTaskManagerResumesConnectAfterJobManagerFailure() : void in class org.apache.flink.runtime.taskmanager.TaskManagerRegistrationTest	From	To
Change Variable Type tm : ActorRef to tm : ActorGateway in method public testSubmitAndExecuteTask() : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest	From	To
Change Variable Type updateMsg : UpdateTaskExecutionState to updateMsg : TaskMessages.UpdateTaskExecutionState in method public handleMessage(message Object) : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest.SimpleLookupFailingUpdateJobManager	From	To
Change Variable Type leaderSessionID : UUID to gateway : ActorGateway in method public testTaskManagerResumesConnectAfterJobManagerFailure() : void in class org.apache.flink.runtime.taskmanager.TaskManagerRegistrationTest	From	To
Change Variable Type taskManager : ActorRef to taskManager : ActorGateway in method public testSubmitAndExecuteTask() : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest	From	To
Extract Method	6
Extract Method public checkJobManagerAddress(config Configuration, expectedAddress String, expectedPort int) : void extracted from public testManualOptionsOverridesYarn() : void in class org.apache.flink.client.CliFrontendAddressConfigurationTest	From	To
Extract Method public checkJobManagerAddress(config Configuration, expectedAddress String, expectedPort int) : void extracted from public testValidConfig() : void in class org.apache.flink.client.CliFrontendAddressConfigurationTest	From	To
Extract Method public checkJobManagerAddress(config Configuration, expectedAddress String, expectedPort int) : void extracted from public testYarnConfig() : void in class org.apache.flink.client.CliFrontendAddressConfigurationTest	From	To
Extract Method public checkJobManagerAddress(config Configuration, expectedAddress String, expectedPort int) : void extracted from public testManualOptionsOverridesConfig() : void in class org.apache.flink.client.CliFrontendAddressConfigurationTest	From	To
Extract Method public checkJobManagerAddress(config Configuration, expectedAddress String, expectedPort int) : void extracted from public testInvalidYarnConfig() : void in class org.apache.flink.client.CliFrontendAddressConfigurationTest	From	To
Extract Method public startCluster(config Configuration, mode StreamingMode, singleActorSystem boolean) : ForkableFlinkMiniCluster extracted from public startCluster(numTaskManagers int, taskManagerNumSlots int, mode StreamingMode, startWebserver boolean, singleActorSystem boolean) : ForkableFlinkMiniCluster in class org.apache.flink.test.util.TestBaseUtils	From	To
Change Attribute Type	13
Change Attribute Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in class org.apache.flink.runtime.instance.AkkaActorGateway	From	To
Change Attribute Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in class org.apache.flink.runtime.instance.InstanceManagerTest	From	To
Change Attribute Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in class org.apache.flink.runtime.client.JobClientActor	From	To
Change Attribute Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in class org.apache.flink.runtime.taskmanager.TaskManagerTest.SimpleJobManager	From	To
Change Attribute Type jobManager : ActorGateway to retriever : JobManagerArchiveRetriever in class org.apache.flink.runtime.webmonitor.handlers.RequestOverviewHandler	From	To
Change Attribute Type address : InetSocketAddress to configuration : Configuration in class org.apache.flink.client.RemoteExecutor	From	To
Change Attribute Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in class org.apache.flink.client.program.ClientTest.SuccessReturningActor	From	To
Change Attribute Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorDeActivator	From	To
Change Attribute Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in class org.apache.flink.client.program.ClientTest.FailureReturningActor	From	To
Change Attribute Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in class org.apache.flink.client.CliFrontendListCancelTest.CliJobManager	From	To
Change Attribute Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in class org.apache.flink.runtime.taskmanager.TaskManagerTest	From	To
Change Attribute Type timeout : Timeout to timeout : FiniteDuration in class org.apache.flink.runtime.taskmanager.TaskManagerTest	From	To
Change Attribute Type leaderSessionID : Option<UUID> to leaderSessionID : UUID in class org.apache.flink.runtime.akka.FlinkUntypedActorTest.PlainFlinkUntypedActor	From	To
Rename Parameter	7
Rename Parameter jobManager : ActorGateway to retriever : JobManagerArchiveRetriever in method public RequestOverviewHandler(retriever JobManagerArchiveRetriever) in class org.apache.flink.runtime.webmonitor.handlers.RequestOverviewHandler	From	To
Rename Parameter source : ActorGateway to retriever : JobManagerArchiveRetriever in method public ExecutionGraphHolder(retriever JobManagerArchiveRetriever, timeout FiniteDuration) in class org.apache.flink.runtime.webmonitor.ExecutionGraphHolder	From	To
Rename Parameter expectedParallelim : int to expectedParallelism : int in method public RunTestingCliFrontend(expectedParallelism int, logging boolean) in class org.apache.flink.client.CliFrontendRunTest.RunTestingCliFrontend	From	To
Rename Parameter jobManager : ActorGateway to retriever : JobManagerArchiveRetriever in method public RequestOverviewHandler(retriever JobManagerArchiveRetriever, timeout FiniteDuration) in class org.apache.flink.runtime.webmonitor.handlers.RequestOverviewHandler	From	To
Rename Parameter target : ActorGateway to retriever : JobManagerArchiveRetriever in method public RequestJobIdsHandler(retriever JobManagerArchiveRetriever) in class org.apache.flink.runtime.webmonitor.handlers.RequestJobIdsHandler	From	To
Rename Parameter source : ActorGateway to retriever : JobManagerArchiveRetriever in method public ExecutionGraphHolder(retriever JobManagerArchiveRetriever) in class org.apache.flink.runtime.webmonitor.ExecutionGraphHolder	From	To
Rename Parameter target : ActorGateway to retriever : JobManagerArchiveRetriever in method public RequestJobIdsHandler(retriever JobManagerArchiveRetriever, timeout FiniteDuration) in class org.apache.flink.runtime.webmonitor.handlers.RequestJobIdsHandler	From	To

b9de4ed37ffa68ef50dc6d6b3819afcc00d1d029

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: