|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testRegistrationTimeout() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testRpcGatewayRetrieval() : void in class org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetrieverTest |
From |
To |
|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public createLeaderRetrievalService() : LeaderRetrievalService in class org.apache.flink.runtime.highavailability.ManualLeaderService |
From |
To |
|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testGatewayRetrievalFailures() : void in class org.apache.flink.runtime.webmonitor.retriever.LeaderGatewayRetrieverTest |
From |
To |
|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testAkkaJobManagerRetrieval() : void in class org.apache.flink.runtime.webmonitor.retriever.impl.AkkaJobManagerRetrieverTest |
From |
To |
|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testConnectionTimeoutAfterJobRegistration() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testJobManagerRetrievalWithHAServices() : void in class org.apache.flink.client.program.ClientConnectionTest |
From |
To |
|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testGuaranteedAnswerIfJobClientDies() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testSubmissionTimeout() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testConnectionTimeoutWithoutJobManagerForRegistration() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testConnectionTimeoutAfterJobSubmission() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testTaskManagerResumesConnectAfterJobManagerFailure() : void in class org.apache.flink.runtime.taskmanager.TaskManagerRegistrationTest |
From |
To |
|
Rename Variable testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testConnectionTimeoutWithoutJobManagerForSubmission() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public createLeaderRetrievalService() : LeaderRetrievalService in class org.apache.flink.runtime.highavailability.ManualLeaderService |
From |
To |
|
Change Variable Type jobMasterLeaderRetrievalService : TestingLeaderRetrievalService to jobMasterLeaderRetrievalService : SettableLeaderRetrievalService in method public testRegisterJobMasterWithFailureLeaderListener() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type retrievalService : TestingLeaderRetrievalService to retrievalService : SettableLeaderRetrievalService in method public notifyRetrievers(index int, leaderId UUID) : void in class org.apache.flink.runtime.highavailability.ManualLeaderService |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testJobManagerRetrievalWithHAServices() : void in class org.apache.flink.client.program.ClientConnectionTest |
From |
To |
|
Change Variable Type leaderRetrievalService : TestingLeaderRetrievalService to leaderRetrievalService : SettableLeaderRetrievalService in method public testInitialJobTimeout() : void in class org.apache.flink.runtime.resourcemanager.JobLeaderIdServiceTest |
From |
To |
|
Change Variable Type leaderRetrievalService : TestingLeaderRetrievalService to leaderRetrievalService : SettableLeaderRetrievalService in method public testAddingJob() : void in class org.apache.flink.runtime.resourcemanager.JobLeaderIdServiceTest |
From |
To |
|
Change Variable Type leaderRetrievalService : TestingLeaderRetrievalService to leaderRetrievalService : SettableLeaderRetrievalService in method public testRemovingJob() : void in class org.apache.flink.runtime.resourcemanager.JobLeaderIdServiceTest |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testTaskManagerResumesConnectAfterJobManagerFailure() : void in class org.apache.flink.runtime.taskmanager.TaskManagerRegistrationTest |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testConnectionTimeoutWithoutJobManagerForSubmission() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Change Variable Type jobMasterLeaderRetrievalService : TestingLeaderRetrievalService to jobMasterLeaderRetrievalService : SettableLeaderRetrievalService in method public testRegisterJobMasterFromInvalidAddress() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type jobMasterLeaderRetrievalService : TestingLeaderRetrievalService to jobMasterLeaderRetrievalService : SettableLeaderRetrievalService in method public testRegisterJobMasterWithUnmatchedLeaderSessionId2() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testRegistrationTimeout() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testRpcGatewayRetrieval() : void in class org.apache.flink.runtime.webmonitor.retriever.impl.RpcGatewayRetrieverTest |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testGatewayRetrievalFailures() : void in class org.apache.flink.runtime.webmonitor.retriever.LeaderGatewayRetrieverTest |
From |
To |
|
Change Variable Type rmLeaderRetrievalService : TestingLeaderRetrievalService to rmLeaderRetrievalService : SettableLeaderRetrievalService in method public testSlotAllocation() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorITCase |
From |
To |
|
Change Variable Type jobMasterLeaderRetrievalService : TestingLeaderRetrievalService to jobMasterLeaderRetrievalService : SettableLeaderRetrievalService in method public testRegisterJobMaster() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |
|
Change Variable Type leaderRetrievalService : TestingLeaderRetrievalService to leaderRetrievalService : SettableLeaderRetrievalService in method public jobTimeoutAfterLostLeadership() : void in class org.apache.flink.runtime.resourcemanager.JobLeaderIdServiceTest |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testAkkaJobManagerRetrieval() : void in class org.apache.flink.runtime.webmonitor.retriever.impl.AkkaJobManagerRetrieverTest |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testConnectionTimeoutAfterJobRegistration() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Change Variable Type myLeaderRetrievalService : TestingLeaderRetrievalService to myLeaderRetrievalService : SettableLeaderRetrievalService in method public testJobRecoveryWhenLosingLeadership() : void in class org.apache.flink.runtime.jobmanager.JobManagerHARecoveryTest |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testGuaranteedAnswerIfJobClientDies() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Change Variable Type jmLeaderRetrievalService : TestingLeaderRetrievalService to jmLeaderRetrievalService : SettableLeaderRetrievalService in method public testHeartbeatTimeoutWithJobManager() : void in class org.apache.flink.runtime.clusterframework.ResourceManagerTest |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testSubmissionTimeout() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testConnectionTimeoutWithoutJobManagerForRegistration() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Change Variable Type testingLeaderRetrievalService : TestingLeaderRetrievalService to settableLeaderRetrievalService : SettableLeaderRetrievalService in method public testConnectionTimeoutAfterJobSubmission() : void in class org.apache.flink.runtime.client.JobClientActorTest |
From |
To |
|
Change Variable Type jobMasterLeaderRetrievalService : TestingLeaderRetrievalService to jobMasterLeaderRetrievalService : SettableLeaderRetrievalService in method public testRegisterJobMasterWithUnmatchedLeaderSessionId1() : void in class org.apache.flink.runtime.resourcemanager.ResourceManagerJobMasterTest |
From |
To |