|
Change Parameter Type metricRegistry : MetricRegistry to jobManagerMetricGroup : JobManagerMetricGroup in method public Dispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, submittedJobGraphStore SubmittedJobGraphStore, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricServiceQueryPath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, restAddress String) in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Parameter Type jobManagerMetricGroup : JobManagerMetricGroup to jobMetricGroup : JobManagerJobMetricGroup in method public JobMaster(rpcService RpcService, jobMasterConfiguration JobMasterConfiguration, resourceId ResourceID, jobGraph JobGraph, highAvailabilityService HighAvailabilityServices, jobManagerSharedServices JobManagerSharedServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobMetricGroup JobManagerJobMetricGroup, jobCompletionActions OnCompletionActions, errorHandler FatalErrorHandler, userCodeLoader ClassLoader, restAddress String, metricQueryServicePath String) in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistry to jobManagerJobMetricGroup : JobManagerJobMetricGroup in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerServices JobManagerSharedServices, jobManagerJobMetricGroup JobManagerJobMetricGroup, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher.DefaultJobManagerRunnerFactory |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistry to jobManagerJobMetricGroup : JobManagerJobMetricGroup in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerServices JobManagerSharedServices, jobManagerJobMetricGroup JobManagerJobMetricGroup, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher.JobManagerRunnerFactory |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistry to jobManagerJobMetricGroup : JobManagerJobMetricGroup in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, jobManagerJobMetricGroup JobManagerJobMetricGroup, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.DispatcherTest.ExpectedJobIdJobManagerRunnerFactory |
From |
To |
|
Rename Parameter metricRegistry : MetricRegistry to jobManagerJobMetricGroup : JobManagerJobMetricGroup in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerServices JobManagerSharedServices, jobManagerJobMetricGroup JobManagerJobMetricGroup, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher.JobManagerRunnerFactory |
From |
To |
|
Rename Parameter metricRegistry : MetricRegistry to jobManagerJobMetricGroup : JobManagerJobMetricGroup in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, jobManagerJobMetricGroup JobManagerJobMetricGroup, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.DispatcherTest.ExpectedJobIdJobManagerRunnerFactory |
From |
To |
|
Rename Parameter metricRegistry : MetricRegistry to jobManagerMetricGroup : JobManagerMetricGroup in method public Dispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, submittedJobGraphStore SubmittedJobGraphStore, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricServiceQueryPath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, restAddress String) in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Parameter jobManagerMetricGroup : JobManagerMetricGroup to jobMetricGroup : JobManagerJobMetricGroup in method public JobMaster(rpcService RpcService, jobMasterConfiguration JobMasterConfiguration, resourceId ResourceID, jobGraph JobGraph, highAvailabilityService HighAvailabilityServices, jobManagerSharedServices JobManagerSharedServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobMetricGroup JobManagerJobMetricGroup, jobCompletionActions OnCompletionActions, errorHandler FatalErrorHandler, userCodeLoader ClassLoader, restAddress String, metricQueryServicePath String) in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Rename Parameter metricRegistry : MetricRegistry to jobManagerJobMetricGroup : JobManagerJobMetricGroup in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerServices JobManagerSharedServices, jobManagerJobMetricGroup JobManagerJobMetricGroup, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher.DefaultJobManagerRunnerFactory |
From |
To |