|
Change Parameter Type leaderRetriever : GatewayRetriever<JobMasterGateway> to leaderRetriever : GatewayRetriever<? extends RestfulGateway> in method public MiniDispatcherRestEndpoint(endpointConfiguration RestServerEndpointConfiguration, leaderRetriever GatewayRetriever<? extends RestfulGateway>, clusterConfiguration Configuration, restConfiguration RestHandlerConfiguration, resourceManagerRetriever GatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService, fatalErrorHandler FatalErrorHandler) in class org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint |
From |
To |
|
Change Parameter Type retriever : GatewayRetriever<T> to retriever : GatewayRetriever<? extends T> in method public StaticFileServerHandler(retriever GatewayRetriever<? extends T>, localJobManagerAddressFuture CompletableFuture<String>, timeout Time, rootPath File) in class org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler |
From |
To |
|
Change Parameter Type resourceManagerGatewayRetriever : GatewayRetriever<ResourceManagerGateway> to resourceManagerGatewayRetriever : LeaderGatewayRetriever<ResourceManagerGateway> in method protected createRestEndpoint(configuration Configuration, dispatcherGatewayRetriever LeaderGatewayRetriever<DispatcherGateway>, resourceManagerGatewayRetriever LeaderGatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService) : MiniDispatcherRestEndpoint in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Change Parameter Type leaderRetriever : GatewayRetriever<DispatcherGateway> to leaderRetriever : GatewayRetriever<? extends DispatcherGateway> in method public BlobServerPortHandler(localRestAddress CompletableFuture<String>, leaderRetriever GatewayRetriever<? extends DispatcherGateway>, timeout Time, headers Map<String,String>) in class org.apache.flink.runtime.rest.handler.job.BlobServerPortHandler |
From |
To |
|
Change Parameter Type leaderRetriever : GatewayRetriever<T> to leaderRetriever : GatewayRetriever<? extends T> in method public WebMonitorEndpoint(endpointConfiguration RestServerEndpointConfiguration, leaderRetriever GatewayRetriever<? extends T>, clusterConfiguration Configuration, restConfiguration RestHandlerConfiguration, resourceManagerRetriever GatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService, fatalErrorHandler FatalErrorHandler) in class org.apache.flink.runtime.webmonitor.WebMonitorEndpoint |
From |
To |
|
Change Parameter Type jobMasterGatewayRetriever : GatewayRetriever<JobMasterGateway> to dispatcherGatewayRetriever : LeaderGatewayRetriever<DispatcherGateway> in method protected createRestEndpoint(configuration Configuration, dispatcherGatewayRetriever LeaderGatewayRetriever<DispatcherGateway>, resourceManagerGatewayRetriever LeaderGatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService) : MiniDispatcherRestEndpoint in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Change Parameter Type leaderRetriever : GatewayRetriever<DispatcherGateway> to leaderRetriever : GatewayRetriever<? extends DispatcherGateway> in method public JobSubmitHandler(localRestAddress CompletableFuture<String>, leaderRetriever GatewayRetriever<? extends DispatcherGateway>, timeout Time, headers Map<String,String>) in class org.apache.flink.runtime.rest.handler.job.JobSubmitHandler |
From |
To |
|
Change Parameter Type leaderRetriever : GatewayRetriever<T> to leaderRetriever : GatewayRetriever<? extends T> in method public tryLoadWebContent(leaderRetriever GatewayRetriever<? extends T>, restAddressFuture CompletableFuture<String>, timeout Time, tmpDir File) : Optional<StaticFileServerHandler<T>> in class org.apache.flink.runtime.webmonitor.WebMonitorUtils |
From |
To |
|
Move 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 from class org.apache.flink.runtime.dispatcher.StandaloneDispatcher to public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerServices JobManagerSharedServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler, restAddress String) : JobManagerRunner from class org.apache.flink.runtime.dispatcher.Dispatcher.DefaultJobManagerRunnerFactory |
From |
To |
|
Move 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 from class org.apache.flink.runtime.dispatcher.DispatcherTest.TestingDispatcher to public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerServices JobManagerSharedServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler, restAddress String) : JobManagerRunner from class org.apache.flink.runtime.dispatcher.Dispatcher.DefaultJobManagerRunnerFactory |
From |
To |
|
Pull Up Attribute private resourceManager : ResourceManager<?> from class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint to private resourceManager : ResourceManager<?> from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Pull Up Attribute private transientBlobCache : TransientBlobCache from class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint to private transientBlobCache : TransientBlobCache from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Pull Up Attribute private dispatcherLeaderRetrievalService : LeaderRetrievalService from class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint to private dispatcherLeaderRetrievalService : LeaderRetrievalService from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Pull Up Attribute private dispatcher : Dispatcher from class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint to private dispatcher : Dispatcher from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Pull Up Attribute private resourceManagerRetrievalService : LeaderRetrievalService from class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint to private resourceManagerRetrievalService : LeaderRetrievalService from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Pull Up Attribute private archivedExecutionGraphStore : ArchivedExecutionGraphStore from class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint to private archivedExecutionGraphStore : ArchivedExecutionGraphStore from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Pull Up Attribute private transientBlobCache : TransientBlobCache from class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint to private transientBlobCache : TransientBlobCache from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Pull Up Attribute private resourceManager : ResourceManager<?> from class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint to private resourceManager : ResourceManager<?> from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Pull Up Attribute private resourceManagerRetrievalService : LeaderRetrievalService from class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint to private resourceManagerRetrievalService : LeaderRetrievalService from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Rename Method protected createDispatcherRestEndpoint(configuration Configuration, dispatcherGatewayRetriever LeaderGatewayRetriever<DispatcherGateway>, resourceManagerGatewayRetriever LeaderGatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService) : DispatcherRestEndpoint renamed to protected createRestEndpoint(configuration Configuration, dispatcherGatewayRetriever LeaderGatewayRetriever<DispatcherGateway>, resourceManagerGatewayRetriever LeaderGatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService) : DispatcherRestEndpoint in class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint |
From |
To |
|
Rename Method protected stopClusterComponents(cleanupHaData boolean) : void renamed to protected stopClusterServices(cleanupHaData boolean) : void in class org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint |
From |
To |
|
Rename Method protected stopClusterComponents(cleanupHaData boolean) : void renamed to protected stopClusterServices(cleanupHaData boolean) : void in class org.apache.flink.mesos.entrypoint.MesosJobClusterEntrypoint |
From |
To |
|
Rename Method protected createJobMasterRestEndpoint(configuration Configuration, jobMasterGatewayRetriever GatewayRetriever<JobMasterGateway>, resourceManagerGatewayRetriever GatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService) : JobMasterRestEndpoint renamed to protected createRestEndpoint(configuration Configuration, dispatcherGatewayRetriever LeaderGatewayRetriever<DispatcherGateway>, resourceManagerGatewayRetriever LeaderGatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService) : MiniDispatcherRestEndpoint in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Pull Up Method protected stopClusterComponents(cleanupHaData boolean) : void from class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint to protected stopClusterServices(cleanupHaData boolean) : void from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Pull Up Method protected stopClusterComponents(cleanupHaData boolean) : void from class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint to protected stopClusterComponents() : void from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Pull Up Method protected startClusterComponents(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry) : void from class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint to protected startClusterComponents(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry) : void from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Rename Parameter jobMasterGatewayRetriever : GatewayRetriever<JobMasterGateway> to dispatcherGatewayRetriever : LeaderGatewayRetriever<DispatcherGateway> in method protected createRestEndpoint(configuration Configuration, dispatcherGatewayRetriever LeaderGatewayRetriever<DispatcherGateway>, resourceManagerGatewayRetriever LeaderGatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService) : MiniDispatcherRestEndpoint in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Rename Parameter jobManagerSharedServices : JobManagerSharedServices to jobManagerServices : JobManagerSharedServices in method public createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, blobServer BlobServer, jobManagerServices JobManagerSharedServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler, restAddress String) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher.DefaultJobManagerRunnerFactory |
From |
To |