|
Rename Method public onReceive(message Object) : void renamed to public handleMessage(message Object) : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest.SimpleLookupFailingUpdateJobManager |
From |
To |
|
Rename Method public enableSnaphotCheckpointing(interval long, checkpointTimeout long, verticesToTrigger List<ExecutionJobVertex>, verticesToWaitFor List<ExecutionJobVertex>, verticesToCommitTo List<ExecutionJobVertex>, actorSystem ActorSystem) : void renamed to public enableSnapshotCheckpointing(interval long, checkpointTimeout long, verticesToTrigger List<ExecutionJobVertex>, verticesToWaitFor List<ExecutionJobVertex>, verticesToCommitTo List<ExecutionJobVertex>, actorSystem ActorSystem, leaderSessionID Option<UUID>) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Rename Method public getInstanceGateway() : InstanceGateway renamed to public getActorGateway() : ActorGateway in class org.apache.flink.runtime.instance.Instance |
From |
To |
|
Rename Method public onReceive(message Object) : void renamed to public handleMessage(message Object) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorDeActivator |
From |
To |
|
Rename Method public onReceive(message Object) : void renamed to public handleMessage(message Object) : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest.SimpleJobManager |
From |
To |
|
Rename Method public onReceive(message Object) : void renamed to public handleMessage(message Object) : void in class org.apache.flink.client.CliFrontendListCancelTest.CliJobManager |
From |
To |
|
Rename Method public onReceive(message Object) : void renamed to public handleMessage(message Object) : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest.SimpleLookupJobManager |
From |
To |
|
Rename Method public onReceive(message Object) : void renamed to protected handleMessage(message Object) : void in class org.apache.flink.runtime.client.JobClientActor |
From |
To |
|
Rename Method public onReceive(message Object) : void renamed to public handleMessage(message Object) : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest.SimplePartitionStateLookupJobManager |
From |
To |
|
Rename Method public getJobManager(options CommandLineOptions) : ActorRef renamed to public getJobManagerGateway(options CommandLineOptions) : ActorGateway in class org.apache.flink.client.CliFrontendListCancelTest.InfoListTestCliFrontend |
From |
To |
|
Rename Method public onReceive(message Object) : void renamed to public handleMessage(message Object) : void in class org.apache.flink.client.program.ClientTest.SuccessReturningActor |
From |
To |
|
Rename Method protected getJobManager(options CommandLineOptions) : ActorRef renamed to protected getJobManagerGateway(options CommandLineOptions) : ActorGateway in class org.apache.flink.client.CliFrontend |
From |
To |
|
Rename Method public onReceive(message Object) : void renamed to public handleMessage(message Object) : void in class org.apache.flink.client.program.ClientTest.FailureReturningActor |
From |
To |
|
Change Parameter Type jobManagerActor : ActorRef to jobManager : ActorGateway in method public RuntimeEnvironment(jobId JobID, jobVertexId JobVertexID, executionId ExecutionAttemptID, taskName String, taskNameWithSubtasks String, subtaskIndex int, parallelism int, jobConfiguration Configuration, taskConfiguration Configuration, userCodeClassLoader ClassLoader, memManager MemoryManager, ioManager IOManager, bcVarManager BroadcastVariableManager, accumulatorRegistry AccumulatorRegistry, splitProvider InputSplitProvider, distCacheEntries Map<String,Future<Path>>, writers ResultPartitionWriter[], inputGates InputGate[], jobManager ActorGateway) in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment |
From |
To |
|
Change Parameter Type gateway : InstanceGateway to gateway : ActorGateway in method public getInstance(gateway ActorGateway) : Instance in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils |
From |
To |
|
Change Parameter Type jobManagerActor : ActorRef to jobManagerActor : ActorGateway in method public Task(tdd TaskDeploymentDescriptor, memManager MemoryManager, ioManager IOManager, networkEnvironment NetworkEnvironment, bcVarManager BroadcastVariableManager, taskManagerActor ActorGateway, jobManagerActor ActorGateway, actorAskTimeout FiniteDuration, libraryCache LibraryCacheManager, fileCache FileCache) in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Parameter Type dataSetId : IntermediateDataSetID to leaderSessionID : UUID in method public SimplePartitionStateLookupJobManagerCreator(leaderSessionID UUID, testActor ActorRef) in class org.apache.flink.runtime.taskmanager.TaskManagerTest.SimplePartitionStateLookupJobManagerCreator |
From |
To |
|
Change Parameter Type jobManager : ActorRef to jobManager : ActorGateway in method public cancelJob(jobManager ActorGateway, jobId JobID, timeout FiniteDuration) : void in class org.apache.flink.runtime.taskmanager.TaskCancelTest |
From |
To |
|
Change Parameter Type jobManager : ActorRef to jobManager : ActorGateway in method public JobManagerPartitionStateChecker(jobManager ActorGateway, taskManager ActorGateway) in class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerPartitionStateChecker |
From |
To |
|
Change Parameter Type taskManager : ActorRef to taskManager : ActorGateway in method public JobManagerPartitionStateChecker(jobManager ActorGateway, taskManager ActorGateway) in class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerPartitionStateChecker |
From |
To |
|
Change Parameter Type listener : ActorRef to listener : ActorGateway in method public registerExecutionListener(listener ActorGateway) : void in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Parameter Type jobManager : ActorRef to jobManager : ActorGateway in method public TaskInputSplitProvider(jobManager ActorGateway, jobId JobID, vertexId JobVertexID, executionID ExecutionAttemptID, userCodeClassLoader ClassLoader, timeout FiniteDuration) in class org.apache.flink.runtime.taskmanager.TaskInputSplitProvider |
From |
To |
|
Change Parameter Type jobManagerRef : ActorRef to jobManagerGateway : ActorGateway in method public associateWithTaskManagerAndJobManager(jobManagerGateway ActorGateway, taskManagerGateway ActorGateway) : void in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Change Parameter Type instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public Instance(actorGateway ActorGateway, connectionInfo InstanceConnectionInfo, id InstanceID, resources HardwareDescription, numberOfSlots int) in class org.apache.flink.runtime.instance.Instance |
From |
To |
|
Change Parameter Type jobManager : ActorRef to jobManagerGateway : ActorGateway in method public submitJobDetached(jobManagerGateway ActorGateway, jobGraph JobGraph, timeout FiniteDuration) : void in class org.apache.flink.runtime.client.JobClient |
From |
To |
|
Change Parameter Type gateway : InstanceGateway to gateway : ActorGateway in method public getInstance(gateway ActorGateway, numberOfSlots int) : Instance in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils |
From |
To |
|
Change Parameter Type jobmanager : ActorRef to jobManagerGateway : ActorGateway in method public InfoListTestCliFrontend(jobManagerGateway ActorGateway) in class org.apache.flink.client.CliFrontendListCancelTest.InfoListTestCliFrontend |
From |
To |
|
Change Parameter Type jobManagerMessageTimeout : Timeout to jobManagerMessageTimeout : FiniteDuration in method public JobManagerResultPartitionConsumableNotifier(executionContext ExecutionContext, jobManager ActorGateway, taskManager ActorGateway, jobManagerMessageTimeout FiniteDuration) in class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerResultPartitionConsumableNotifier |
From |
To |
|
Change Parameter Type taskManagerActor : ActorRef to taskManagerActor : ActorGateway in method public Task(tdd TaskDeploymentDescriptor, memManager MemoryManager, ioManager IOManager, networkEnvironment NetworkEnvironment, bcVarManager BroadcastVariableManager, taskManagerActor ActorGateway, jobManagerActor ActorGateway, actorAskTimeout FiniteDuration, libraryCache LibraryCacheManager, fileCache FileCache) in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Parameter Type sender : ActorRef to sender : ActorGateway in method public forward(message Object, sender ActorGateway) : void in class org.apache.flink.runtime.instance.ActorGateway |
From |
To |
|
Change Parameter Type sender : ActorRef to sender : ActorGateway in method public forward(message Object, sender ActorGateway) : void in class org.apache.flink.runtime.instance.BaseTestingActorGateway |
From |
To |
|
Change Parameter Type jobManager : ActorRef to jobManagerGateway : ActorGateway in method public uploadJarFiles(jobGraph JobGraph, jobManagerGateway ActorGateway, timeout FiniteDuration) : void in class org.apache.flink.runtime.client.JobClient |
From |
To |
|
Change Parameter Type listener : ActorRef to listener : ActorGateway in method public registerJobStatusListener(listener ActorGateway) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Parameter Type jobManager : ActorRef to jobManager : ActorGateway in method public JobManagerResultPartitionConsumableNotifier(executionContext ExecutionContext, jobManager ActorGateway, taskManager ActorGateway, jobManagerMessageTimeout FiniteDuration) in class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerResultPartitionConsumableNotifier |
From |
To |
|
Change Parameter Type timeout : Timeout to timeout : FiniteDuration in method public TaskInputSplitProvider(jobManager ActorGateway, jobId JobID, vertexId JobVertexID, executionID ExecutionAttemptID, userCodeClassLoader ClassLoader, timeout FiniteDuration) in class org.apache.flink.runtime.taskmanager.TaskInputSplitProvider |
From |
To |
|
Change Parameter Type jobManager : ActorRef to jobManagerGateway : ActorGateway in method public submitJobAndWait(actorSystem ActorSystem, jobManagerGateway ActorGateway, jobGraph JobGraph, timeout FiniteDuration, sysoutLogUpdates boolean) : SerializedJobExecutionResult in class org.apache.flink.runtime.client.JobClient |
From |
To |
|
Change Parameter Type listener : ActorRef to listener : ActorGateway in method public registerExecutionListener(listener ActorGateway) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Parameter Type taskManager : ActorRef to taskManager : ActorGateway in method public JobManagerResultPartitionConsumableNotifier(executionContext ExecutionContext, jobManager ActorGateway, taskManager ActorGateway, jobManagerMessageTimeout FiniteDuration) in class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerResultPartitionConsumableNotifier |
From |
To |
|
Change Parameter Type taskManagerRef : ActorRef to taskManagerGateway : ActorGateway in method public associateWithTaskManagerAndJobManager(jobManagerGateway ActorGateway, taskManagerGateway ActorGateway) : void in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Rename Variable jobManagerRef : ActorRef to gateway : ActorGateway in method public testRequestNextInputSplitWithInvalidExecutionID() : void in class org.apache.flink.runtime.taskmanager.TaskInputSplitProviderTest |
From |
To |
|
Rename Variable instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public testCancelConcurrentlyToDeploying_CallsNotOvertaking() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Rename Variable instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public testCancelFromRunningDidNotFindTask() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Rename Variable jobManager : ActorRef to jobManagerGateway : ActorGateway in method protected list(args String[]) : int in class org.apache.flink.client.CliFrontend |
From |
To |
|
Rename Variable jm : ActorRef to jmGateway : ActorGateway in method public testLocalFlinkMiniClusterWithMultipleTaskManagers() : void in class org.apache.flink.test.runtime.minicluster.LocalFlinkMiniClusterITCase |
From |
To |
|
Rename Variable instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public registerTaskManager(taskManager ActorRef, connectionInfo InstanceConnectionInfo, resources HardwareDescription, numberOfSlots int, leaderSessionID Option<UUID>) : InstanceID in class org.apache.flink.runtime.instance.InstanceManager |
From |
To |
|
Rename Variable instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public testCancelFromRunning() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Rename Variable instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public testCancelConcurrentlyToDeploying_CallsOvertaking() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Rename Variable instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public testRepeatedCancelFromRunning() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Rename Variable tmClosure : ActorRef to tm : ActorRef in method public testSubmitAndExecuteTask() : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest |
From |
To |
|
Change Variable Type gateway : InstanceGateway to gateway : ActorGateway in method public testCancelCallFails() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Change Variable Type gateway : InstanceGateway to gateway : ActorGateway in method private sendUpdatePartitionInfoRpcCall(consumerSlot SimpleSlot, updatePartitionInfo UpdatePartitionInfo) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type jobManager : ActorRef to jobManager : ActorGateway in method protected cancel(args String[]) : int in class org.apache.flink.client.CliFrontend |
From |
To |
|
Change Variable Type instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public registerTaskManager(taskManager ActorRef, connectionInfo InstanceConnectionInfo, resources HardwareDescription, numberOfSlots int, leaderSessionID Option<UUID>) : InstanceID in class org.apache.flink.runtime.instance.InstanceManager |
From |
To |
|
Change Variable Type listener : ActorRef to listener : ActorGateway in method private notifyJobStatusChange(newState JobStatus, error Throwable) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Variable Type instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public testCancelConcurrentlyToDeploying_CallsNotOvertaking() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Change Variable Type timeout : Timeout to timeout : FiniteDuration in method public testRequestNextInputSplitWithInvalidExecutionID() : void in class org.apache.flink.runtime.taskmanager.TaskInputSplitProviderTest |
From |
To |
|
Change Variable Type instanceGateway : ExecutionGraphTestUtils.SimpleInstanceGateway to instanceGateway : ExecutionGraphTestUtils.SimpleActorGateway in method public testBuildDeploymentDescriptor() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphDeploymentTest |
From |
To |
|
Change Variable Type instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public testCancelConcurrentlyToDeploying_CallsOvertaking() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Change Variable Type gateway : InstanceGateway to gateway : ActorGateway in method private sendCancelRpcCall() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type jobManager : ActorRef to jobManager : ActorGateway in method public testCoordinatorShutsDownOnSuccess() : void in class org.apache.flink.runtime.checkpoint.CoordinatorShutdownTest |
From |
To |
|
Change Variable Type listener : ActorRef to listener : ActorGateway in method private notifyObservers(newState ExecutionState, error Throwable) : void in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Variable Type jobManagerRef : ActorRef to gateway : ActorGateway in method public testRequestNextInputSplitWithInvalidExecutionID() : void in class org.apache.flink.runtime.taskmanager.TaskInputSplitProviderTest |
From |
To |
|
Change Variable Type gateway : InstanceGateway to gateway : ActorGateway in method public sendMessageToCurrentExecution(message Serializable, attemptID ExecutionAttemptID) : void in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Variable Type jobManager : ActorRef to jobManager : ActorGateway in method public testCoordinatorShutsDownOnFailure() : void in class org.apache.flink.runtime.checkpoint.CoordinatorShutdownTest |
From |
To |
|
Change Variable Type gateway : InstanceGateway to gateway : ActorGateway in method public testSendCancelAndReceiveFail() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Change Variable Type instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public testCancelFromRunningDidNotFindTask() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Change Variable Type jobManager : ActorRef to jobManagerGateway : ActorGateway in method protected list(args String[]) : int in class org.apache.flink.client.CliFrontend |
From |
To |
|
Change Variable Type gateway : InstanceGateway to gateway : ActorGateway in method private sendFailIntermediateResultPartitionsRpcCall() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public testRepeatedCancelFromRunning() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Change Variable Type gateway : InstanceGateway to gateway : ActorGateway in method public deployToSlot(slot SimpleSlot) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type jm : ActorRef to jmGateway : ActorGateway in method public testLocalFlinkMiniClusterWithMultipleTaskManagers() : void in class org.apache.flink.test.runtime.minicluster.LocalFlinkMiniClusterITCase |
From |
To |
|
Change Variable Type instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public testCancelFromRunning() : void in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest |
From |
To |
|
Change Variable Type listener : ActorRef to listener : ActorGateway in method package notifyExecutionChange(vertexId JobVertexID, subtask int, executionID ExecutionAttemptID, newExecutionState ExecutionState, error Throwable) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Attribute Type jobManager : ActorRef to jobManagerGateway : ActorGateway in class org.apache.flink.test.accumulators.AccumulatorLiveITCase |
From |
To |
|
Change Attribute Type jobStatusListenerActors : List<ActorRef> to jobStatusListenerActors : List<ActorGateway> in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Attribute Type jobStatusListener : ActorRef to jobStatusListener : ActorGateway in class org.apache.flink.runtime.checkpoint.CheckpointCoordinator |
From |
To |
|
Change Attribute Type jobmanager : ActorRef to jobManagerGateway : ActorGateway in class org.apache.flink.client.CliFrontendListCancelTest.InfoListTestCliFrontend |
From |
To |
|
Change Attribute Type executionListenerActors : List<ActorRef> to executionListenerActors : List<ActorGateway> in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Attribute Type jobManager : ActorRef to jobManager : ActorGateway in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Attribute Type jobManager : ActorRef to jobManager : ActorGateway in class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerResultPartitionConsumableNotifier |
From |
To |
|
Change Attribute Type jobManager : ActorRef to jobManager : ActorGateway in class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerPartitionStateChecker |
From |
To |
|
Change Attribute Type listenerActor : ActorRef to listenerGateway : ActorGateway in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Change Attribute Type timeout : Timeout to timeout : FiniteDuration in class org.apache.flink.runtime.taskmanager.TaskInputSplitProvider |
From |
To |
|
Change Attribute Type taskManagerMock : ActorRef to taskManagerGateway : ActorGateway in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Change Attribute Type INSTANCE : DummyInstanceGateway to INSTANCE : DummyActorGateway in class org.apache.flink.runtime.instance.DummyActorGateway |
From |
To |
|
Change Attribute Type jobManager : ActorRef to jobManager : ActorGateway in class org.apache.flink.runtime.taskmanager.TaskInputSplitProvider |
From |
To |
|
Change Attribute Type taskManager : ActorRef to taskManager : ActorGateway in class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerResultPartitionConsumableNotifier |
From |
To |
|
Change Attribute Type taskManager : ActorRef to taskManager : ActorGateway in class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerPartitionStateChecker |
From |
To |
|
Change Attribute Type jobManagerActor : ActorRef to jobManager : ActorGateway in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment |
From |
To |
|
Change Attribute Type jobManager : ActorRef to jobManager : ActorGateway in class org.apache.flink.runtime.jobmanager.JobSubmitTest |
From |
To |
|
Change Attribute Type instanceGateway : InstanceGateway to actorGateway : ActorGateway in class org.apache.flink.runtime.instance.Instance |
From |
To |
|
Change Attribute Type jobManagerMock : ActorRef to jobManagerGateway : ActorGateway in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Change Attribute Type executionListenerActors : List<ActorRef> to executionListenerActors : List<ActorGateway> in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Attribute Type actorAskTimeout : Timeout to actorAskTimeout : FiniteDuration in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Change Attribute Type jobManagerMessageTimeout : Timeout to jobManagerMessageTimeout : FiniteDuration in class org.apache.flink.runtime.io.network.NetworkEnvironment.JobManagerResultPartitionConsumableNotifier |
From |
To |
|
Change Attribute Type taskManager : ActorRef to taskManager : ActorGateway in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Rename Parameter jobManagerActor : ActorRef to jobManager : ActorGateway in method public RuntimeEnvironment(jobId JobID, jobVertexId JobVertexID, executionId ExecutionAttemptID, taskName String, taskNameWithSubtasks String, subtaskIndex int, parallelism int, jobConfiguration Configuration, taskConfiguration Configuration, userCodeClassLoader ClassLoader, memManager MemoryManager, ioManager IOManager, bcVarManager BroadcastVariableManager, accumulatorRegistry AccumulatorRegistry, splitProvider InputSplitProvider, distCacheEntries Map<String,Future<Path>>, writers ResultPartitionWriter[], inputGates InputGate[], jobManager ActorGateway) in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment |
From |
To |
|
Rename Parameter dataSetId : IntermediateDataSetID to leaderSessionID : UUID in method public SimplePartitionStateLookupJobManagerCreator(leaderSessionID UUID, testActor ActorRef) in class org.apache.flink.runtime.taskmanager.TaskManagerTest.SimplePartitionStateLookupJobManagerCreator |
From |
To |
|
Rename Parameter jobManager : ActorRef to jobManagerGateway : ActorGateway in method public uploadJarFiles(jobGraph JobGraph, jobManagerGateway ActorGateway, timeout FiniteDuration) : void in class org.apache.flink.runtime.client.JobClient |
From |
To |
|
Rename Parameter jobmanager : ActorRef to jobManagerGateway : ActorGateway in method public InfoListTestCliFrontend(jobManagerGateway ActorGateway) in class org.apache.flink.client.CliFrontendListCancelTest.InfoListTestCliFrontend |
From |
To |
|
Rename Parameter instanceGateway : InstanceGateway to actorGateway : ActorGateway in method public Instance(actorGateway ActorGateway, connectionInfo InstanceConnectionInfo, id InstanceID, resources HardwareDescription, numberOfSlots int) in class org.apache.flink.runtime.instance.Instance |
From |
To |
|
Rename Parameter jobManagerRef : ActorRef to jobManagerGateway : ActorGateway in method public associateWithTaskManagerAndJobManager(jobManagerGateway ActorGateway, taskManagerGateway ActorGateway) : void in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Rename Parameter jobManager : ActorRef to jobManagerGateway : ActorGateway in method public submitJobAndWait(actorSystem ActorSystem, jobManagerGateway ActorGateway, jobGraph JobGraph, timeout FiniteDuration, sysoutLogUpdates boolean) : SerializedJobExecutionResult in class org.apache.flink.runtime.client.JobClient |
From |
To |
|
Rename Parameter jobManager : ActorRef to jobManagerGateway : ActorGateway in method public submitJobDetached(jobManagerGateway ActorGateway, jobGraph JobGraph, timeout FiniteDuration) : void in class org.apache.flink.runtime.client.JobClient |
From |
To |
|
Rename Parameter taskManagerRef : ActorRef to taskManagerGateway : ActorGateway in method public associateWithTaskManagerAndJobManager(jobManagerGateway ActorGateway, taskManagerGateway ActorGateway) : void in class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |