|
Change Parameter Type futureExecutor : Executor to futureExecutor : ScheduledExecutorService in method public ExecutionGraph(futureExecutor ScheduledExecutorService, ioExecutor 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 futureExecutor : Executor to futureExecutor : ScheduledExecutorService in method public buildGraph(prior ExecutionGraph, jobGraph JobGraph, jobManagerConfig Configuration, futureExecutor ScheduledExecutorService, ioExecutor Executor, classLoader ClassLoader, recoveryFactory CheckpointRecoveryFactory, timeout Time, restartStrategy RestartStrategy, metrics MetricGroup, parallelismForAutoMax int, log Logger) : ExecutionGraph in class org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder |
From |
To |
|
Change Parameter Type executorService : ExecutorService to executorService : ScheduledExecutorService in method public JobManagerServices(executorService ScheduledExecutorService, libraryCacheManager BlobLibraryCacheManager, restartStrategyFactory RestartStrategyFactory, rpcAskTimeout Time) in class org.apache.flink.runtime.jobmaster.JobManagerServices |
From |
To |
|
Change Parameter Type futureExecutor : Executor to futureExecutor : ScheduledExecutorService in method public TestingFailingHAJobManager(flinkConfiguration Configuration, futureExecutor ScheduledExecutorService, ioExecutor Executor, instanceManager InstanceManager, scheduler Scheduler, libraryCacheManager BlobLibraryCacheManager, archive ActorRef, restartStrategyFactory RestartStrategyFactory, timeout FiniteDuration, leaderElectionService LeaderElectionService, submittedJobGraphs SubmittedJobGraphStore, checkpointRecoveryFactory CheckpointRecoveryFactory, jobRecoveryTimeout FiniteDuration, metricsRegistry Option<MetricRegistry>, recoveredJobs Collection<JobID>) in class org.apache.flink.runtime.jobmanager.JobManagerHARecoveryTest.TestingFailingHAJobManager |
From |
To |
|
Change Parameter Type executor : Executor to executor : ScheduledExecutorService in method public getExecutionVertex(id JobVertexID, executor ScheduledExecutorService) : ExecutionJobVertex in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils |
From |
To |
|
Change Parameter Type executorService : ExecutorService to executorService : ScheduledExecutorService in method public JobMaster(jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityService HighAvailabilityServices, executorService ScheduledExecutorService, libraryCacheManager BlobLibraryCacheManager, restartStrategyFactory RestartStrategyFactory, rpcAskTimeout Time, jobManagerMetricGroup JobManagerMetricGroup, jobCompletionActions OnCompletionActions, errorHandler FatalErrorHandler, userCodeLoader ClassLoader) in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |