|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method package ExecutionGraph(executor Executor, jobId JobID, jobName String, jobConfig Configuration, serializedConfig SerializedValue<ExecutionConfig>, timeout Time, restartStrategy RestartStrategy) in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Parameter Type localJobManagerAddressPromise : Future<String> to localJobManagerAddressPromise : scala.concurrent.Future<String> in method public TaskManagerLogHandler(retriever JobManagerRetriever, executor ExecutionContextExecutor, localJobManagerAddressPromise scala.concurrent.Future<String>, timeout FiniteDuration, fileMode FileMode, config Configuration, httpsEnabled boolean) in class org.apache.flink.runtime.webmonitor.handlers.TaskManagerLogHandler |
From |
To |
|
Change Parameter Type executionContext : ExecutionContext to executor : Executor in method public Execution(executor Executor, vertex ExecutionVertex, attemptNumber int, startTimestamp long, timeout Time) in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public ExecutionJobVertex(graph ExecutionGraph, jobVertex JobVertex, defaultParallelism int, timeout Time) in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex |
From |
To |
|
Change Parameter Type result : TaskOperationResult... to successfulOperations : int in method public CancelSequenceActorGateway(executionContext ExecutionContext, successfulOperations int) in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest.CancelSequenceActorGateway |
From |
To |
|
Change Parameter Type cause : Exception to cause : Throwable in method public cancelStackTraceSample(sampleId int, cause Throwable) : void in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinator |
From |
To |
|
Change Parameter Type delayBetweenSamples : FiniteDuration to delayBetweenSamples : Time in method public BackPressureStatsTracker(coordinator StackTraceSampleCoordinator, cleanUpInterval int, numSamples int, delayBetweenSamples Time) in class org.apache.flink.runtime.webmonitor.BackPressureStatsTracker |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public ExecutionVertex(jobVertex ExecutionJobVertex, subTaskIndex int, producedDataSets IntermediateResult[], timeout Time, createTimestamp long) in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public ExecutionVertex(jobVertex ExecutionJobVertex, subTaskIndex int, producedDataSets IntermediateResult[], timeout Time) in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Parameter Type executionContext : ExecutionContext to executor : Executor in method public getExecutionVertex(id JobVertexID, executor Executor) : ExecutionJobVertex in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils |
From |
To |
|
Change Parameter Type executionContext : ExecutionContext to executor : Executor in method public ExecutionGraph(executor Executor, jobId JobID, jobName String, jobConfig Configuration, serializedConfig SerializedValue<ExecutionConfig>, timeout Time, restartStrategy RestartStrategy, requiredJarFiles List<BlobKey>, requiredClasspaths List<URL>, userClassLoader ClassLoader, metricGroup MetricGroup) in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Parameter Type taskManagerActorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public SimpleSlot(jobID JobID, owner SlotOwner, location TaskManagerLocation, slotNumber int, taskManagerGateway TaskManagerGateway) in class org.apache.flink.runtime.instance.SimpleSlot |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public Execution(executor Executor, vertex ExecutionVertex, attemptNumber int, startTimestamp long, timeout Time) in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Parameter Type actorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public AllocatedSlot(slotAllocationId AllocationID, jobID JobID, location TaskManagerLocation, slotNumber int, resourceProfile ResourceProfile, taskManagerGateway TaskManagerGateway) in class org.apache.flink.runtime.jobmanager.slots.AllocatedSlot |
From |
To |
|
Change Parameter Type gateway : ActorGateway to gateway : TaskManagerGateway in method public getInstance(gateway TaskManagerGateway) : Instance in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils |
From |
To |
|
Change Parameter Type taskManagerActorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method protected Slot(jobID JobID, owner SlotOwner, location TaskManagerLocation, slotNumber int, taskManagerGateway TaskManagerGateway, parent SharedSlot, groupID AbstractID) in class org.apache.flink.runtime.instance.Slot |
From |
To |
|
Change Parameter Type gateway : ActorGateway to gateway : TaskManagerGateway in method public getInstance(gateway TaskManagerGateway, numberOfSlots int) : Instance in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils |
From |
To |
|
Change Parameter Type executionContext : ExecutionContext to executor : Executor in method package ExecutionGraph(executor Executor, jobId JobID, jobName String, jobConfig Configuration, serializedConfig SerializedValue<ExecutionConfig>, timeout Time, restartStrategy RestartStrategy) in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Parameter Type taskManagerActorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public SharedSlot(jobID JobID, owner SlotOwner, location TaskManagerLocation, slotNumber int, taskManagerGateway TaskManagerGateway, assignmentGroup SlotSharingGroupAssignment) in class org.apache.flink.runtime.instance.SharedSlot |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public ExecutionJobVertex(graph ExecutionGraph, jobVertex JobVertex, defaultParallelism int, timeout Time, createTimestamp long) in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex |
From |
To |
|
Change Parameter Type taskManagerActorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public SimpleSlot(jobID JobID, owner SlotOwner, location TaskManagerLocation, slotNumber int, taskManagerGateway TaskManagerGateway, parent SharedSlot, groupID AbstractID) in class org.apache.flink.runtime.instance.SimpleSlot |
From |
To |
|
Change Parameter Type taskManagerActorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public SharedSlot(jobID JobID, owner SlotOwner, location TaskManagerLocation, slotNumber int, taskManagerGateway TaskManagerGateway, assignmentGroup SlotSharingGroupAssignment, parent SharedSlot, groupId AbstractID) in class org.apache.flink.runtime.instance.SharedSlot |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public ExecutionGraph(executor Executor, jobId JobID, jobName String, jobConfig Configuration, serializedConfig SerializedValue<ExecutionConfig>, timeout Time, restartStrategy RestartStrategy, requiredJarFiles List<BlobKey>, requiredClasspaths List<URL>, userClassLoader ClassLoader, metricGroup MetricGroup) in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Parameter Type actorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public Instance(taskManagerGateway TaskManagerGateway, location TaskManagerLocation, id InstanceID, resources HardwareDescription, numberOfSlots int) in class org.apache.flink.runtime.instance.Instance |
From |
To |
|
Change Variable Type gateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method private sendFailIntermediateResultPartitionsRpcCall() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type gateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public stop() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type executionContext : ExecutionContext to executor : Executor in method public triggerStackTraceSample(vertex ExecutionJobVertex) : boolean in class org.apache.flink.runtime.webmonitor.BackPressureStatsTracker |
From |
To |
|
Change Variable Type actorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public testExecutionGraphRestartTimeMetric() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphMetricsTest |
From |
To |
|
Change Variable Type portFuture : Future<Object> to portFuture : scala.concurrent.Future<Object> in method protected respondAsLeader(ctx ChannelHandlerContext, routed Routed, jobManager ActorGateway) : void in class org.apache.flink.runtime.webmonitor.handlers.TaskManagerLogHandler |
From |
To |
|
Change Variable Type gateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public deployToSlot(slot SimpleSlot) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type gateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method private sendCancelRpcCall() : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type taskManagerGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public testUpdate() : void in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcherTest |
From |
To |
|
Change Variable Type response : ResponseStackTraceSampleSuccess to response : StackTraceSampleResponse in method public testTriggerStackTraceSampleMessage() : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest |
From |
To |
|
Change Variable Type actorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public registerTaskManager(taskManagerGateway TaskManagerGateway, taskManagerLocation TaskManagerLocation, resources HardwareDescription, numberOfSlots int) : InstanceID in class org.apache.flink.runtime.instance.InstanceManager |
From |
To |
|
Rename Parameter executionContext : ExecutionContext to executor : Executor in method public Execution(executor Executor, vertex ExecutionVertex, attemptNumber int, startTimestamp long, timeout Time) in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Rename Parameter taskManagerActorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public SimpleSlot(jobID JobID, owner SlotOwner, location TaskManagerLocation, slotNumber int, taskManagerGateway TaskManagerGateway) in class org.apache.flink.runtime.instance.SimpleSlot |
From |
To |
|
Rename Parameter taskManagerActorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public SimpleSlot(jobID JobID, owner SlotOwner, location TaskManagerLocation, slotNumber int, taskManagerGateway TaskManagerGateway, parent SharedSlot, groupID AbstractID) in class org.apache.flink.runtime.instance.SimpleSlot |
From |
To |
|
Rename Parameter actorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public AllocatedSlot(slotAllocationId AllocationID, jobID JobID, location TaskManagerLocation, slotNumber int, resourceProfile ResourceProfile, taskManagerGateway TaskManagerGateway) in class org.apache.flink.runtime.jobmanager.slots.AllocatedSlot |
From |
To |
|
Rename Parameter taskManagerActorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public SharedSlot(jobID JobID, owner SlotOwner, location TaskManagerLocation, slotNumber int, taskManagerGateway TaskManagerGateway, assignmentGroup SlotSharingGroupAssignment, parent SharedSlot, groupId AbstractID) in class org.apache.flink.runtime.instance.SharedSlot |
From |
To |
|
Rename Parameter executionContext : ExecutionContext to executor : Executor in method public getExecutionVertex(id JobVertexID, executor Executor) : ExecutionJobVertex in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils |
From |
To |
|
Rename Parameter taskManagerActorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method protected Slot(jobID JobID, owner SlotOwner, location TaskManagerLocation, slotNumber int, taskManagerGateway TaskManagerGateway, parent SharedSlot, groupID AbstractID) in class org.apache.flink.runtime.instance.Slot |
From |
To |
|
Rename Parameter executionContext : ExecutionContext to executor : Executor in method package ExecutionGraph(executor Executor, jobId JobID, jobName String, jobConfig Configuration, serializedConfig SerializedValue<ExecutionConfig>, timeout Time, restartStrategy RestartStrategy) in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Rename Parameter executionContext : ExecutionContext to executor : Executor in method public ExecutionGraph(executor Executor, jobId JobID, jobName String, jobConfig Configuration, serializedConfig SerializedValue<ExecutionConfig>, timeout Time, restartStrategy RestartStrategy, requiredJarFiles List<BlobKey>, requiredClasspaths List<URL>, userClassLoader ClassLoader, metricGroup MetricGroup) in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Rename Parameter taskManagerActorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public SharedSlot(jobID JobID, owner SlotOwner, location TaskManagerLocation, slotNumber int, taskManagerGateway TaskManagerGateway, assignmentGroup SlotSharingGroupAssignment) in class org.apache.flink.runtime.instance.SharedSlot |
From |
To |
|
Rename Parameter result : TaskOperationResult... to successfulOperations : int in method public CancelSequenceActorGateway(executionContext ExecutionContext, successfulOperations int) in class org.apache.flink.runtime.executiongraph.ExecutionVertexCancelTest.CancelSequenceActorGateway |
From |
To |
|
Rename Parameter actorGateway : ActorGateway to taskManagerGateway : TaskManagerGateway in method public Instance(taskManagerGateway TaskManagerGateway, location TaskManagerLocation, id InstanceID, resources HardwareDescription, numberOfSlots int) in class org.apache.flink.runtime.instance.Instance |
From |
To |