|
Change Parameter Type backPressureStatsTrackerImpl : BackPressureStatsTrackerImpl to backPressureStatsTracker : BackPressureStatsTracker in method public JobManagerSharedServices(scheduledExecutorService ScheduledExecutorService, libraryCacheManager LibraryCacheManager, restartStrategyFactory RestartStrategyFactory, stackTraceSampleCoordinator StackTraceSampleCoordinator, backPressureStatsTracker BackPressureStatsTracker, backPressureStatsTrackerCleanupInterval Time, timeout Time) in class org.apache.flink.runtime.jobmaster.JobManagerSharedServices |
From |
To |
|
Change Parameter Type jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in method protected createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.StandaloneDispatcher |
From |
To |
|
Change Parameter Type jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in method protected createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.DispatcherTest.TestingDispatcher |
From |
To |
|
Change Parameter Type jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in method protected createJobManagerRunner(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, jobManagerSharedServices JobManagerSharedServices, heartbeatServices HeartbeatServices, blobServer BlobServer, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Change Parameter Type libraryCacheManager : BlobLibraryCacheManager to libraryCacheManager : LibraryCacheManager in method public JobManagerSharedServices(scheduledExecutorService ScheduledExecutorService, libraryCacheManager LibraryCacheManager, restartStrategyFactory RestartStrategyFactory, stackTraceSampleCoordinator StackTraceSampleCoordinator, backPressureStatsTracker BackPressureStatsTracker, backPressureStatsTrackerCleanupInterval Time, timeout Time) in class org.apache.flink.runtime.jobmaster.JobManagerSharedServices |
From |
To |
|
Change Parameter Type jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in method public JobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, haServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, metricRegistry MetricRegistry, toNotifyOnComplete OnCompletionActions, errorHandler FatalErrorHandler, restAddress String) in class org.apache.flink.runtime.jobmaster.JobManagerRunner |
From |
To |
|
Change Parameter Type jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in method protected abstract createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Attribute backPressureStatsTrackerImpl : BackPressureStatsTrackerImpl to backPressureStatsTracker : BackPressureStatsTracker in class org.apache.flink.runtime.jobmaster.JobManagerSharedServices |
From |
To |
|
Rename Attribute jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Attribute jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in class org.apache.flink.runtime.minicluster.MiniClusterJobDispatcher |
From |
To |
|
Rename Attribute executorService : ScheduledExecutorService to scheduledExecutorService : ScheduledExecutorService in class org.apache.flink.runtime.jobmaster.JobManagerSharedServices |
From |
To |
|
Rename Attribute executor : Executor to scheduledExecutorService : ScheduledExecutorService in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Rename Attribute jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Rename Attribute rpcAskTimeout : Time to timeout : Time in class org.apache.flink.runtime.jobmaster.JobManagerSharedServices |
From |
To |
|
Change Attribute Type executor : Executor to scheduledExecutorService : ScheduledExecutorService in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Attribute Type jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Change Attribute Type libraryCacheManager : BlobLibraryCacheManager to libraryCacheManager : LibraryCacheManager in class org.apache.flink.runtime.jobmaster.JobManagerSharedServices |
From |
To |
|
Change Attribute Type backPressureStatsTrackerImpl : BackPressureStatsTrackerImpl to backPressureStatsTracker : BackPressureStatsTracker in class org.apache.flink.runtime.jobmaster.JobManagerSharedServices |
From |
To |
|
Change Attribute Type jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Attribute Type jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in class org.apache.flink.runtime.minicluster.MiniClusterJobDispatcher |
From |
To |
|
Rename Parameter backPressureStatsTrackerImpl : BackPressureStatsTrackerImpl to backPressureStatsTracker : BackPressureStatsTracker in method public JobManagerSharedServices(scheduledExecutorService ScheduledExecutorService, libraryCacheManager LibraryCacheManager, restartStrategyFactory RestartStrategyFactory, stackTraceSampleCoordinator StackTraceSampleCoordinator, backPressureStatsTracker BackPressureStatsTracker, backPressureStatsTrackerCleanupInterval Time, timeout Time) in class org.apache.flink.runtime.jobmaster.JobManagerSharedServices |
From |
To |
|
Rename Parameter jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in method protected createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.StandaloneDispatcher |
From |
To |
|
Rename Parameter jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in method protected createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.DispatcherTest.TestingDispatcher |
From |
To |
|
Rename Parameter jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in method protected createJobManagerRunner(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, jobManagerSharedServices JobManagerSharedServices, heartbeatServices HeartbeatServices, blobServer BlobServer, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Rename Parameter jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in method protected abstract createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Parameter jobManagerServices : JobManagerServices to jobManagerSharedServices : JobManagerSharedServices in method public JobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, haServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, metricRegistry MetricRegistry, toNotifyOnComplete OnCompletionActions, errorHandler FatalErrorHandler, restAddress String) in class org.apache.flink.runtime.jobmaster.JobManagerRunner |
From |
To |
|
Rename Parameter executorService : ScheduledExecutorService to scheduledExecutorService : ScheduledExecutorService in method public JobManagerSharedServices(scheduledExecutorService ScheduledExecutorService, libraryCacheManager LibraryCacheManager, restartStrategyFactory RestartStrategyFactory, stackTraceSampleCoordinator StackTraceSampleCoordinator, backPressureStatsTracker BackPressureStatsTracker, backPressureStatsTrackerCleanupInterval Time, timeout Time) in class org.apache.flink.runtime.jobmaster.JobManagerSharedServices |
From |
To |