|
Change Parameter Type resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method package TestingDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler) in class org.apache.flink.runtime.dispatcher.TestingDispatcher |
From |
To |
|
Change Parameter Type resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method package HATestingDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, fencingTokens Queue<DispatcherId>) in class org.apache.flink.runtime.dispatcher.DispatcherHATest.HATestingDispatcher |
From |
To |
|
Change Parameter Type resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method public Dispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, submittedJobGraphStore SubmittedJobGraphStore, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricServiceQueryPath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Parameter Type resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method public MiniDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist, jobGraph JobGraph, executionMode JobClusterEntrypoint.ExecutionMode) in class org.apache.flink.runtime.dispatcher.MiniDispatcher |
From |
To |
|
Change Parameter Type resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method public StandaloneDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) in class org.apache.flink.runtime.dispatcher.StandaloneDispatcher |
From |
To |
|
Change Parameter Type resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method public createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) : Dispatcher in class org.apache.flink.runtime.dispatcher.SessionDispatcherFactory |
From |
To |
|
Change Parameter Type resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method public createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) : MiniDispatcher in class org.apache.flink.runtime.dispatcher.JobDispatcherFactory |
From |
To |
|
Rename Parameter resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method public createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) : MiniDispatcher in class org.apache.flink.runtime.dispatcher.JobDispatcherFactory |
From |
To |
|
Rename Parameter resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method package TestingDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler) in class org.apache.flink.runtime.dispatcher.TestingDispatcher |
From |
To |
|
Rename Parameter resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method public Dispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, submittedJobGraphStore SubmittedJobGraphStore, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricServiceQueryPath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Parameter resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method package HATestingDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, fencingTokens Queue<DispatcherId>) in class org.apache.flink.runtime.dispatcher.DispatcherHATest.HATestingDispatcher |
From |
To |
|
Rename Parameter resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method public MiniDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist, jobGraph JobGraph, executionMode JobClusterEntrypoint.ExecutionMode) in class org.apache.flink.runtime.dispatcher.MiniDispatcher |
From |
To |
|
Rename Parameter resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method public StandaloneDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) in class org.apache.flink.runtime.dispatcher.StandaloneDispatcher |
From |
To |
|
Rename Parameter resourceManagerGateway : ResourceManagerGateway to resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> in method public createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, historyServerArchivist HistoryServerArchivist) : Dispatcher in class org.apache.flink.runtime.dispatcher.SessionDispatcherFactory |
From |
To |