|
Move Method protected createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<?> from class org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint to public createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<RegisteredMesosWorkerNode> from class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerFactory |
From |
To |
|
Move Method protected createRestEndpoint(configuration Configuration, dispatcherGatewayRetriever LeaderGatewayRetriever<DispatcherGateway>, resourceManagerGatewayRetriever LeaderGatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService) : MiniDispatcherRestEndpoint from class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint to public createRestEndpoint(configuration Configuration, dispatcherGatewayRetriever LeaderGatewayRetriever<DispatcherGateway>, resourceManagerGatewayRetriever LeaderGatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService, fatalErrorHandler FatalErrorHandler) : WebMonitorEndpoint<RestfulGateway> from class org.apache.flink.runtime.rest.JobRestEndpointFactory |
From |
To |
|
Move 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 from class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint to public 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 from class org.apache.flink.runtime.dispatcher.SessionDispatcherFactory |
From |
To |
|
Move Method protected createRestEndpoint(configuration Configuration, dispatcherGatewayRetriever LeaderGatewayRetriever<DispatcherGateway>, resourceManagerGatewayRetriever LeaderGatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService) : DispatcherRestEndpoint from class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint to public createRestEndpoint(configuration Configuration, dispatcherGatewayRetriever LeaderGatewayRetriever<DispatcherGateway>, resourceManagerGatewayRetriever LeaderGatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService, fatalErrorHandler FatalErrorHandler) : WebMonitorEndpoint<DispatcherGateway> from class org.apache.flink.runtime.rest.SessionRestEndpointFactory |
From |
To |
|
Move Method protected createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<?> from class org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint to public createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<YarnWorkerNode> from class org.apache.flink.yarn.entrypoint.YarnResourceManagerFactory |
From |
To |
|
Move Method protected retrieveJobGraph(configuration Configuration) : JobGraph from class org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint to public retrieveJobGraph(configuration Configuration) : JobGraph from class org.apache.flink.runtime.entrypoint.FileJobGraphRetriever |
From |
To |
|
Move 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 from class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint to public 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) : MiniDispatcher from class org.apache.flink.runtime.dispatcher.JobDispatcherFactory |
From |
To |
|
Move Method protected createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<?> from class org.apache.flink.mesos.entrypoint.MesosJobClusterEntrypoint to public createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<RegisteredMesosWorkerNode> from class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerFactory |
From |
To |
|
Move Method private createPackagedProgram() : PackagedProgram from class org.apache.flink.container.entrypoint.StandaloneJobClusterEntryPoint to private createPackagedProgram() : PackagedProgram from class org.apache.flink.container.entrypoint.ClassPathJobGraphRetriever |
From |
To |
|
Move Method protected createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<?> from class org.apache.flink.container.entrypoint.StandaloneJobClusterEntryPoint to public createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<ResourceID> from class org.apache.flink.runtime.resourcemanager.StandaloneResourceManagerFactory |
From |
To |
|
Move Method protected retrieveJobGraph(configuration Configuration) : JobGraph from class org.apache.flink.container.entrypoint.StandaloneJobClusterEntryPoint to public retrieveJobGraph(configuration Configuration) : JobGraph from class org.apache.flink.container.entrypoint.ClassPathJobGraphRetriever |
From |
To |
|
Move Method protected createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<?> from class org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint to public createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<ResourceID> from class org.apache.flink.runtime.resourcemanager.StandaloneResourceManagerFactory |
From |
To |
|
Move Method protected createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<?> from class org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint to public createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<YarnWorkerNode> from class org.apache.flink.yarn.entrypoint.YarnResourceManagerFactory |
From |
To |
|
Move Method protected retrieveJobGraph(configuration Configuration) : JobGraph from class org.apache.flink.mesos.entrypoint.MesosJobClusterEntrypoint to public retrieveJobGraph(configuration Configuration) : JobGraph from class org.apache.flink.runtime.entrypoint.FileJobGraphRetriever |
From |
To |
|
Change Return Type Dispatcher to MiniDispatcher in method public 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) : MiniDispatcher in class org.apache.flink.runtime.dispatcher.JobDispatcherFactory |
From |
To |
|
Change Return Type MiniDispatcherRestEndpoint to WebMonitorEndpoint<RestfulGateway> in method public createRestEndpoint(configuration Configuration, dispatcherGatewayRetriever LeaderGatewayRetriever<DispatcherGateway>, resourceManagerGatewayRetriever LeaderGatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService, fatalErrorHandler FatalErrorHandler) : WebMonitorEndpoint<RestfulGateway> in class org.apache.flink.runtime.rest.JobRestEndpointFactory |
From |
To |
|
Change Return Type DispatcherRestEndpoint to WebMonitorEndpoint<DispatcherGateway> in method public createRestEndpoint(configuration Configuration, dispatcherGatewayRetriever LeaderGatewayRetriever<DispatcherGateway>, resourceManagerGatewayRetriever LeaderGatewayRetriever<ResourceManagerGateway>, transientBlobService TransientBlobService, executor Executor, metricQueryServiceRetriever MetricQueryServiceRetriever, leaderElectionService LeaderElectionService, fatalErrorHandler FatalErrorHandler) : WebMonitorEndpoint<DispatcherGateway> in class org.apache.flink.runtime.rest.SessionRestEndpointFactory |
From |
To |
|
Change Return Type ResourceManager<?> to ResourceManager<YarnWorkerNode> in method public createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<YarnWorkerNode> in class org.apache.flink.yarn.entrypoint.YarnResourceManagerFactory |
From |
To |
|
Change Return Type ResourceManager<?> to ResourceManager<RegisteredMesosWorkerNode> in method public createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<RegisteredMesosWorkerNode> in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerFactory |
From |
To |
|
Change Return Type ResourceManager<?> to ResourceManager<ResourceID> in method public createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, clusterInformation ClusterInformation, webInterfaceUrl String) : ResourceManager<ResourceID> in class org.apache.flink.runtime.resourcemanager.StandaloneResourceManagerFactory |
From |
To |