|
Change Parameter Type partitionConnectionInfo : InstanceConnectionInfo to partitionConnectionInfo : TaskManagerLocation in method public PartialInputChannelDeploymentDescriptor(resultId IntermediateDataSetID, partitionID ResultPartitionID, partitionConnectionInfo TaskManagerLocation, partitionConnectionIndex int) in class org.apache.flink.runtime.deployment.PartialInputChannelDeploymentDescriptor |
From |
To |
|
Change Parameter Type o : InstanceConnectionInfo to o : TaskManagerLocation in method public compareTo(o TaskManagerLocation) : int in class org.apache.flink.runtime.taskmanager.TaskManagerLocation |
From |
To |
|
Change Parameter Type connectionInfo : InstanceConnectionInfo to connectionInfo : TaskManagerLocation in method public Instance(actorGateway ActorGateway, connectionInfo TaskManagerLocation, resourceId ResourceID, id InstanceID, resources HardwareDescription, numberOfSlots int) in class org.apache.flink.runtime.instance.Instance |
From |
To |
|
Change Parameter Type connectionInfo : InstanceConnectionInfo to connectionInfo : TaskManagerLocation in method public ConnectionID(connectionInfo TaskManagerLocation, connectionIndex int) in class org.apache.flink.runtime.io.network.ConnectionID |
From |
To |
|
Change Parameter Type connectionInfo : InstanceConnectionInfo to connectionInfo : TaskManagerLocation in method public registerTaskManager(taskManager ActorRef, resourceID ResourceID, connectionInfo TaskManagerLocation, resources HardwareDescription, numberOfSlots int, leaderSessionID UUID) : InstanceID in class org.apache.flink.runtime.instance.InstanceManager |
From |
To |
|
Change Variable Type location : InstanceConnectionInfo to location : TaskManagerLocation in method public handleRequest(jobVertex ExecutionJobVertex, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.SubtasksTimesHandler |
From |
To |
|
Change Variable Type serCopy : InstanceConnectionInfo to serCopy : TaskManagerLocation in method public testSerialization() : void in class org.apache.flink.runtime.taskmanager.TaskManagerLocationTest |
From |
To |
|
Change Variable Type consumerConnectionInfo : InstanceConnectionInfo to consumerConnectionInfo : TaskManagerLocation in method public createInputChannelDeploymentDescriptor(consumerExecution Execution) : InputChannelDeploymentDescriptor in class org.apache.flink.runtime.deployment.PartialInputChannelDeploymentDescriptor |
From |
To |
|
Change Variable Type instanceConnectionInfo : InstanceConnectionInfo to taskManagerLocation : TaskManagerLocation in method public testExecutionGraphRestartTimeMetric() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphMetricsTest |
From |
To |
|
Change Variable Type connection : InstanceConnectionInfo to connection : TaskManagerLocation in method public getInstance(ipAddress byte[], dataPort int, hostname String) : Instance in class org.apache.flink.runtime.executiongraph.VertexLocationConstraintTest |
From |
To |
|
Change Variable Type location : InstanceConnectionInfo to location : TaskManagerLocation in method public handleRequest(jobVertex ExecutionJobVertex, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.JobVertexDetailsHandler |
From |
To |
|
Change Variable Type location : InstanceConnectionInfo to location : TaskManagerLocation in method public handleRequest(execAttempt Execution, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.SubtaskExecutionAttemptDetailsHandler |
From |
To |
|
Change Variable Type location : InstanceConnectionInfo to location : TaskManagerLocation in method public handleRequest(graph ExecutionGraph, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.JobExceptionsHandler |
From |
To |
|
Change Variable Type other : InstanceConnectionInfo to that : TaskManagerLocation in method public equals(obj Object) : boolean in class org.apache.flink.runtime.taskmanager.TaskManagerLocation |
From |
To |
|
Change Variable Type location : InstanceConnectionInfo to location : TaskManagerLocation in method public handleRequest(jobVertex ExecutionJobVertex, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.SubtasksAllAccumulatorsHandler |
From |
To |
|
Change Variable Type instanceConnectionInfos : Set<InstanceConnectionInfo> to taskManagerLocations : Set<TaskManagerLocation> in method public testInstanceRegistering() : void in class org.apache.flink.runtime.instance.InstanceManagerTest |
From |
To |
|
Change Variable Type location : InstanceConnectionInfo to location : TaskManagerLocation in method public handleRequest(jobVertex ExecutionJobVertex, params Map<String,String>) : String in class org.apache.flink.runtime.webmonitor.handlers.JobVertexTaskManagersHandler |
From |
To |
|
Change Variable Type partitionConnectionInfo : InstanceConnectionInfo to partitionConnectionInfo : TaskManagerLocation in method public fromEdge(partition IntermediateResultPartition, producer Execution) : PartialInputChannelDeploymentDescriptor in class org.apache.flink.runtime.deployment.PartialInputChannelDeploymentDescriptor |
From |
To |