|
Change Parameter Type jsonArchivist : JsonArchivist to historyServerArchivist : HistoryServerArchivist in method public MiniDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, restAddress String, historyServerArchivist HistoryServerArchivist, jobGraph JobGraph, executionMode JobClusterEntrypoint.ExecutionMode) in class org.apache.flink.runtime.dispatcher.MiniDispatcher |
From |
To |
|
Change Parameter Type jsonArchivist : JsonArchivist to historyServerArchivist : HistoryServerArchivist 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, historyServerArchivist HistoryServerArchivist) in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Parameter Type jsonArchivist : JsonArchivist to historyServerArchivist : HistoryServerArchivist in method protected abstract createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, restAddress String, historyServerArchivist HistoryServerArchivist) : Dispatcher in class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Change Parameter Type jsonArchivist : JsonArchivist to historyServerArchivist : HistoryServerArchivist in method public StandaloneDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, restAddress String, historyServerArchivist HistoryServerArchivist) in class org.apache.flink.runtime.dispatcher.StandaloneDispatcher |
From |
To |
|
Change Parameter Type jsonArchivist : JsonArchivist to historyServerArchivist : HistoryServerArchivist in method protected createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, restAddress String, historyServerArchivist HistoryServerArchivist) : Dispatcher in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Change Parameter Type jsonArchivist : JsonArchivist to historyServerArchivist : HistoryServerArchivist in method protected createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, restAddress String, historyServerArchivist HistoryServerArchivist) : Dispatcher in class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint |
From |
To |
|
Rename Parameter jsonArchivist : JsonArchivist to historyServerArchivist : HistoryServerArchivist 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, historyServerArchivist HistoryServerArchivist) in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Parameter jsonArchivist : JsonArchivist to historyServerArchivist : HistoryServerArchivist in method protected abstract createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, restAddress String, historyServerArchivist HistoryServerArchivist) : Dispatcher in class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Rename Parameter jsonArchivist : JsonArchivist to historyServerArchivist : HistoryServerArchivist in method protected createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, restAddress String, historyServerArchivist HistoryServerArchivist) : Dispatcher in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Rename Parameter jsonArchivist : JsonArchivist to historyServerArchivist : HistoryServerArchivist in method public StandaloneDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, restAddress String, historyServerArchivist HistoryServerArchivist) in class org.apache.flink.runtime.dispatcher.StandaloneDispatcher |
From |
To |
|
Rename Parameter jsonArchivist : JsonArchivist to historyServerArchivist : HistoryServerArchivist in method protected createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, fatalErrorHandler FatalErrorHandler, restAddress String, historyServerArchivist HistoryServerArchivist) : Dispatcher in class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint |
From |
To |
|
Rename Parameter jsonArchivist : JsonArchivist to historyServerArchivist : HistoryServerArchivist in method public MiniDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, jobManagerMetricGroup JobManagerMetricGroup, metricQueryServicePath String, archivedExecutionGraphStore ArchivedExecutionGraphStore, jobManagerRunnerFactory JobManagerRunnerFactory, fatalErrorHandler FatalErrorHandler, restAddress String, historyServerArchivist HistoryServerArchivist, jobGraph JobGraph, executionMode JobClusterEntrypoint.ExecutionMode) in class org.apache.flink.runtime.dispatcher.MiniDispatcher |
From |
To |