|
Change Parameter Type service : BlobService to service : Closeable in method package addShutdownHook(service Closeable, logger Logger) : Thread in class org.apache.flink.runtime.blob.BlobUtils |
From |
To |
|
Change Parameter Type blobService : BlobService to blobService : BlobServer in method public JobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, haServices HighAvailabilityServices, blobService BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, toNotifyOnComplete OnCompletionActions, errorHandler FatalErrorHandler) in class org.apache.flink.runtime.jobmaster.JobManagerRunner |
From |
To |
|
Change Parameter Type blobService : BlobService to blobService : BlobServer in method protected createJobManagerRunner(configuration Configuration, resourceId ResourceID, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobService BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint |
From |
To |
|
Change Parameter Type blobService : BlobService to blobServer : BlobServer in method protected createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.StandaloneDispatcher |
From |
To |
|
Change Parameter Type blobService : BlobService to blobServer : BlobServer in method protected createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.DispatcherTest.TestingDispatcher |
From |
To |
|
Change Parameter Type blobService : BlobService to blobServer : BlobServer in method protected abstract createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Change Parameter Type blobService : BlobService to blobServer : BlobServer in method public fromConfiguration(config Configuration, blobServer BlobServer) : JobManagerServices in class org.apache.flink.runtime.jobmaster.JobManagerServices |
From |
To |
|
Change Parameter Type blobService : BlobService to blobService : BlobServer in method public JobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, haServices HighAvailabilityServices, blobService BlobServer, heartbeatServices HeartbeatServices, toNotifyOnComplete OnCompletionActions, errorHandler FatalErrorHandler) in class org.apache.flink.runtime.jobmaster.JobManagerRunner |
From |
To |
|
Rename Variable libraryCacheManager : BlobLibraryCacheManager to libCache : BlobLibraryCacheManager in method public testLibraryCacheManagerTaskCleanup() : void in class org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManagerTest |
From |
To |
|
Rename Variable keys : List<BlobKey> to keys1 : List<BlobKey> in method public testLibraryCacheManagerJobCleanup() : void in class org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManagerTest |
From |
To |
|
Rename Variable libraryCacheManager : BlobLibraryCacheManager to blobServer : BlobServer in method public testHeartbeatTimeoutWithTaskManager() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest |
From |
To |
|
Rename Variable blobSocketAddress : InetSocketAddress to serverAddress : InetSocketAddress in method public testLibraryCacheManagerJobCleanup() : void in class org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManagerTest |
From |
To |
|
Rename Variable libraryCacheManager : BlobLibraryCacheManager to libCache : BlobLibraryCacheManager in method public testLibraryCacheManagerJobCleanup() : void in class org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManagerTest |
From |
To |
|
Rename Variable executionId2 : ExecutionAttemptID to attempt2 : ExecutionAttemptID in method public testLibraryCacheManagerTaskCleanup() : void in class org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManagerTest |
From |
To |
|
Rename Variable blobSocketAddress : InetSocketAddress to serverAddress : InetSocketAddress in method public testLibraryCacheManagerTaskCleanup() : void in class org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManagerTest |
From |
To |
|
Rename Variable executionId1 : ExecutionAttemptID to attempt1 : ExecutionAttemptID in method public testLibraryCacheManagerTaskCleanup() : void in class org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManagerTest |
From |
To |
|
Rename Parameter blobService : BlobService to blobServer : BlobServer in method protected createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.StandaloneDispatcher |
From |
To |
|
Rename Parameter blobService : BlobService to blobServer : BlobServer in method protected createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.DispatcherTest.TestingDispatcher |
From |
To |
|
Rename Parameter blobService : BlobService to blobServer : BlobServer in method protected abstract createJobManagerRunner(resourceId ResourceID, jobGraph JobGraph, configuration Configuration, rpcService RpcService, highAvailabilityServices HighAvailabilityServices, blobServer BlobServer, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, onCompleteActions OnCompletionActions, fatalErrorHandler FatalErrorHandler) : JobManagerRunner in class org.apache.flink.runtime.dispatcher.Dispatcher |
From |
To |
|
Rename Parameter id : JobID to jobId : JobID in method public getClassLoader(jobId JobID) : ClassLoader in class org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager |
From |
To |
|
Rename Parameter blobService : BlobService to blobServer : BlobServer in method public fromConfiguration(config Configuration, blobServer BlobServer) : JobManagerServices in class org.apache.flink.runtime.jobmaster.JobManagerServices |
From |
To |
|
Rename Parameter libraries : Collection<BlobKey> to requiredLibraries : Collection<BlobKey> in method package LibraryCacheEntry(requiredLibraries Collection<BlobKey>, requiredClasspaths Collection<URL>, libraryURLs URL[], initialReference ExecutionAttemptID) in class org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.LibraryCacheEntry |
From |
To |