|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method public MiniClusterJobDispatcher(config Configuration, haServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, numJobManagers int, rpcServices RpcService[]) in class org.apache.flink.runtime.minicluster.MiniClusterJobDispatcher |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected abstract createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler) : ResourceManager<?> in class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected createJobManagerRunner(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, jobManagerServices JobManagerServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler) : ResourceManager<?> in class org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method public ResourceManager(rpcService RpcService, resourceManagerEndpointId String, resourceId ResourceID, resourceManagerConfiguration ResourceManagerConfiguration, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, slotManager SlotManager, metricRegistry MetricRegistry, jobLeaderIdService JobLeaderIdService, fatalErrorHandler FatalErrorHandler) in class org.apache.flink.runtime.resourcemanager.ResourceManager |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler) : ResourceManager<?> in class org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected startResourceManagers(configuration Configuration, haServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, numResourceManagers int, resourceManagerRpcServices RpcService[]) : ResourceManagerRunner[] in class org.apache.flink.runtime.minicluster.MiniCluster |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method public TestingMesosResourceManager(rpcService RpcService, resourceManagerEndpointId String, resourceId ResourceID, resourceManagerConfiguration ResourceManagerConfiguration, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, slotManager SlotManager, metricRegistry MetricRegistry, jobLeaderIdService JobLeaderIdService, fatalErrorHandler FatalErrorHandler, flinkConfig Configuration, mesosServices MesosServices, mesosConfig MesosConfiguration, taskManagerParameters MesosTaskManagerParameters, taskManagerContainerSpec ContainerSpecification) in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerTest.TestingMesosResourceManager |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, jobManagerServices JobManagerServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.StandaloneDispatcher |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, jobManagerServices JobManagerServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.DispatcherTest.TestingDispatcher |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method public MiniClusterJobDispatcher(config Configuration, rpcService RpcService, haServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry) in class org.apache.flink.runtime.minicluster.MiniClusterJobDispatcher |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected abstract createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler) : ResourceManager<?> in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler) : ResourceManager<?> in class org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method public YarnResourceManager(rpcService RpcService, resourceManagerEndpointId String, resourceId ResourceID, flinkConfig Configuration, env Map<String,String>, resourceManagerConfiguration ResourceManagerConfiguration, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, slotManager SlotManager, metricRegistry MetricRegistry, jobLeaderIdService JobLeaderIdService, fatalErrorHandler FatalErrorHandler) in class org.apache.flink.yarn.YarnResourceManager |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method public StandaloneDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, restAddress Optional<String>) in class org.apache.flink.runtime.dispatcher.StandaloneDispatcher |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected abstract createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, jobManagerServices JobManagerServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected startClusterComponents(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry) : void in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected startClusterComponents(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry) : void in class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method public StandaloneResourceManager(rpcService RpcService, resourceManagerEndpointId String, resourceId ResourceID, resourceManagerConfiguration ResourceManagerConfiguration, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, slotManager SlotManager, metricRegistry MetricRegistry, jobLeaderIdService JobLeaderIdService, fatalErrorHandler FatalErrorHandler) in class org.apache.flink.runtime.resourcemanager.StandaloneResourceManager |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected startClusterComponents(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry) : void in class org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method public MesosResourceManager(rpcService RpcService, resourceManagerEndpointId String, resourceId ResourceID, resourceManagerConfiguration ResourceManagerConfiguration, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, slotManager SlotManager, metricRegistry MetricRegistry, jobLeaderIdService JobLeaderIdService, fatalErrorHandler FatalErrorHandler, flinkConfig Configuration, mesosServices MesosServices, mesosConfig MesosConfiguration, taskManagerParameters MesosTaskManagerParameters, taskManagerContainerSpec ContainerSpecification) in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected Dispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, restAddress Optional<String>) in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected abstract startClusterComponents(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry) : void in class org.apache.flink.runtime.entrypoint.ClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method public JobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, haServices HighAvailabilityServices, heartbeatServices HeartbeatServices, jobManagerServices JobManagerServices, metricRegistry MetricRegistry, toNotifyOnComplete OnCompletionActions, errorHandler FatalErrorHandler) in class org.apache.flink.runtime.jobmaster.JobManagerRunner |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler) : ResourceManager<?> in class org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected startTaskManagers(configuration Configuration, haServices HighAvailabilityServices, metricRegistry MetricRegistry, numTaskManagers int, taskManagerRpcServices RpcService[]) : TaskExecutor[] in class org.apache.flink.runtime.minicluster.MiniCluster |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected createResourceManager(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler) : ResourceManager<?> in class org.apache.flink.mesos.entrypoint.MesosJobClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method public ResourceManagerRunner(resourceId ResourceID, resourceManagerEndpointId String, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry) in class org.apache.flink.runtime.resourcemanager.ResourceManagerRunner |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected createDispatcher(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, restAddress Optional<String>) : Dispatcher in class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected startClusterComponents(configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry) : void in class org.apache.flink.mesos.entrypoint.MesosJobClusterEntrypoint |
From |
To |
|
Change Parameter Type metricRegistry : MetricRegistryImpl to metricRegistry : MetricRegistry in method protected TestingDispatcher(rpcService RpcService, endpointId String, configuration Configuration, highAvailabilityServices HighAvailabilityServices, resourceManagerGateway ResourceManagerGateway, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler, jobManagerRunner JobManagerRunner, expectedJobId JobID) in class org.apache.flink.runtime.dispatcher.DispatcherTest.TestingDispatcher |
From |
To |