Toggle navigation
Home
org.apache.flink.runtime.instance.ActorGateway to org.apache.flink.runtime.jobmaster.JobManagerGateway
No. of Instances - 34
No. of Commits - 2
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Rename Variable
jobManager
to
jobManagerGateway
jobManager
to
jobManagerGateway
jobManager
to
jobManagerGateway
jobManager
to
jobManagerGateway
jobManager
to
jobManagerGateway
jobManager
to
jobManagerGateway
jobManager
to
jobManagerGateway
jobManager
to
jobManagerGateway
jobManager
to
jobManagerGateway
jobManager
to
jobManagerGateway
jobManager
to
jobManagerGateway
jobManager
to
jobManagerGateway
jobManager
to
jobManagerGateway
Cascading Type Change (Different)
FiniteDuration
to
Time
FiniteDuration
to
Time
FiniteDuration
to
Time
FiniteDuration
to
Time
FiniteDuration
to
Time
FiniteDuration
to
Time
FiniteDuration
to
Time
JobManagerMessages.RequestTaskManagerInstance
to
InstanceID
FiniteDuration
to
Time
FiniteDuration
to
Time
FiniteDuration
to
Time
FiniteDuration
to
Time
Add or Remove Method invocation
when(jobManagerGateway.ask(isA(RequestJobDetails.class),any(Time.class)))
to
when(jobManagerGateway.requestJobDetails(anyBoolean(),anyBoolean(),any(Time.class)))
Future$.MODULE$.successful((Object)new MultipleJobsDetails(new JobDetails[0],new JobDetails[0]))
to
CompletableFuture.completedFuture(new MultipleJobsDetails(new JobDetails[0],new JobDetails[0]))
isA(JobManagerMessages.RequestRegisteredTaskManagers$.class)
to
taskManager
when(jobManagerGateway.ask(taskManager,any(Time.class)))
to
when(jobManagerGateway.requestTaskManagerInstances(any(Time.class)))
registeredTaskManagersAnswer
to
Collections.singleton(taskManager)
when(jobManagerGateway.path())
to
when(jobManagerGateway.getAddress())
when(retriever.getJobManagerGatewayAndWebPort())
to
when(retriever.getJobManagerGatewayNow())
Option.apply(new scala.Tuple2<ActorGateway,Integer>(jobManagerGateway,0))
to
Optional.of(jobManagerGateway)
when(jobManager.ask(any(jobId),any(Time.class)))
to
when(jobManager.cancelJobWithSavepoint(eq(jobId),anyString(),any(Time.class)))
future
to
CompletableFuture.completedFuture("foobar")
eq(FiniteDuration.apply(timeout,"ms"))
to
any(Time.class)
ask
to
cancelJobWithSavepoint
eq(FiniteDuration.apply(timeout,"ms"))
to
any(Time.class)
ask
to
cancelJobWithSavepoint
when(jobManager.ask(any(jobId),any(Time.class)))
to
when(jobManager.cancelJobWithSavepoint(eq(jobId),eq("custom-directory"),any(Time.class)))
ask
to
cancelJobWithSavepoint
when(jobManagerGateway.ask(isA(JobManagerMessages.getRequestBlobManagerPort().getClass()),any(Time.class)))
to
when(jobManagerGateway.requestBlobServerPort(any(Time.class)))
Future$.MODULE$.successful((Object)5)
to
CompletableFuture.completedFuture(1337)
when(jobManagerGateway.ask(isA(InstanceID.class),any(Time.class)))
to
when(jobManagerGateway.requestTaskManagerInstance(any(InstanceID.class),any(Time.class)))
Future$.MODULE$.successful((Object)new JobManagerMessages.TaskManagerInstance(Option.apply(taskManager)))
to
CompletableFuture.completedFuture(Optional.of(taskManager))
when(retriever.getJobManagerGatewayAndWebPort())
to
when(retriever.getJobManagerGatewayNow())
Option.apply(new scala.Tuple2<ActorGateway,Integer>(jobManagerGateway,0))
to
Optional.of(jobManagerGateway)
Time.milliseconds(timeout.toMillis())
to
timeout
any(Object.class)
to
successfulCancelWithSavepoint
when(jobManager.ask(any(jobId),any(Time.class)))
to
when(jobManager.cancelJobWithSavepoint(eq(jobId),eq("custom-directory"),any(Time.class)))
ask
to
cancelJobWithSavepoint
ask
to
cancelJobWithSavepoint
when(jobManager.ask(any(jobId),any(Time.class)))
to
when(jobManager.cancelJobWithSavepoint(eq(jobId),anyString(),any(Time.class)))
future
to
CompletableFuture.completedFuture("foobar")
FiniteDuration.apply(timeout,"ms")
to
jobId
eq(jobId)
to
any(Time.class)
ask
to
cancelJobWithSavepoint
Other
Object.class
to
jobId
Object.class
to
jobId
new AkkaJobManagerGateway(jobManager)
to
jobManagerGateway
Object.class
to
jobId
Object.class
to
jobId