|
Change Parameter Type jobManagerJobMetricGroup : JobManagerJobMetricGroup to jobManagerJobMetricGroupFactory : JobManagerJobMetricGroupFactory in method public JobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, haServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, jobManagerJobMetricGroupFactory JobManagerJobMetricGroupFactory, metricQueryServicePath String, restAddress String) in class org.apache.flink.runtime.jobmaster.JobManagerRunner |
From |
To |
|
Change Parameter Type jobMetricGroup : JobManagerJobMetricGroup to jobMetricGroupFactory : JobManagerJobMetricGroupFactory in method public JobMaster(rpcService RpcService, jobMasterConfiguration JobMasterConfiguration, resourceId ResourceID, jobGraph JobGraph, highAvailabilityService HighAvailabilityServices, jobManagerSharedServices JobManagerSharedServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobMetricGroupFactory JobManagerJobMetricGroupFactory, jobCompletionActions OnCompletionActions, errorHandler FatalErrorHandler, userCodeLoader ClassLoader, restAddress String, metricQueryServicePath String) in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Change Parameter Type jobManagerJobMetricGroup : JobManagerJobMetricGroup to jobManagerJobMetricGroupFactory : JobManagerJobMetricGroupFactory in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerServices JobManagerSharedServices, jobManagerJobMetricGroupFactory JobManagerJobMetricGroupFactory, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher.DefaultJobManagerRunnerFactory |
From |
To |
|
Change Parameter Type jobManagerJobMetricGroup : JobManagerJobMetricGroup to jobManagerJobMetricGroupFactory : JobManagerJobMetricGroupFactory in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerServices JobManagerSharedServices, jobManagerJobMetricGroupFactory JobManagerJobMetricGroupFactory, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher.JobManagerRunnerFactory |
From |
To |
|
Change Parameter Type jobManagerJobMetricGroup : JobManagerJobMetricGroup to jobManagerJobMetricGroupFactory : JobManagerJobMetricGroupFactory in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, jobManagerJobMetricGroupFactory JobManagerJobMetricGroupFactory, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.DispatcherTest.ExpectedJobIdJobManagerRunnerFactory |
From |
To |
|
Change Parameter Type jobManagerJobMetricGroup : JobManagerJobMetricGroup to jobManagerJobMetricGroupFactory : JobManagerJobMetricGroupFactory in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, jobManagerJobMetricGroupFactory JobManagerJobMetricGroupFactory, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.MiniDispatcherTest.TestingJobManagerRunnerFactory |
From |
To |
|
Rename Parameter jobMetricGroup : JobManagerJobMetricGroup to jobMetricGroupFactory : JobManagerJobMetricGroupFactory in method public JobMaster(rpcService RpcService, jobMasterConfiguration JobMasterConfiguration, resourceId ResourceID, jobGraph JobGraph, highAvailabilityService HighAvailabilityServices, jobManagerSharedServices JobManagerSharedServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobMetricGroupFactory JobManagerJobMetricGroupFactory, jobCompletionActions OnCompletionActions, errorHandler FatalErrorHandler, userCodeLoader ClassLoader, restAddress String, metricQueryServicePath String) in class org.apache.flink.runtime.jobmaster.JobMaster |
From |
To |
|
Rename Parameter jobManagerJobMetricGroup : JobManagerJobMetricGroup to jobManagerJobMetricGroupFactory : JobManagerJobMetricGroupFactory in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerServices JobManagerSharedServices, jobManagerJobMetricGroupFactory JobManagerJobMetricGroupFactory, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher.DefaultJobManagerRunnerFactory |
From |
To |
|
Rename Parameter jobManagerJobMetricGroup : JobManagerJobMetricGroup to jobManagerJobMetricGroupFactory : JobManagerJobMetricGroupFactory in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerServices JobManagerSharedServices, jobManagerJobMetricGroupFactory JobManagerJobMetricGroupFactory, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher.JobManagerRunnerFactory |
From |
To |
|
Rename Parameter jobManagerJobMetricGroup : JobManagerJobMetricGroup to jobManagerJobMetricGroupFactory : JobManagerJobMetricGroupFactory in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, jobManagerJobMetricGroupFactory JobManagerJobMetricGroupFactory, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.DispatcherTest.ExpectedJobIdJobManagerRunnerFactory |
From |
To |
|
Rename Parameter jobManagerJobMetricGroup : JobManagerJobMetricGroup to jobManagerJobMetricGroupFactory : JobManagerJobMetricGroupFactory in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, jobManagerJobMetricGroupFactory JobManagerJobMetricGroupFactory, metricQueryServicePath String, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.MiniDispatcherTest.TestingJobManagerRunnerFactory |
From |
To |
|
Rename Parameter jobManagerJobMetricGroup : JobManagerJobMetricGroup to jobManagerJobMetricGroupFactory : JobManagerJobMetricGroupFactory in method public JobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, haServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerSharedServices JobManagerSharedServices, jobManagerJobMetricGroupFactory JobManagerJobMetricGroupFactory, metricQueryServicePath String, restAddress String) in class org.apache.flink.runtime.jobmaster.JobManagerRunner |
From |
To |