|
Change Variable Type rpc : TestingSerialRpcService to rpc : TestingRpcService in method public testHeartbeatTimeoutWithResourceManager() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Change Variable Type rpc : TestingSerialRpcService to rpc : TestingRpcService in method public testTaskSubmission() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Change Variable Type rpc : TestingSerialRpcService to rpc : TestingRpcService in method public testHeartbeatTimeoutWithJobManager() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Change Variable Type rpc : TestingSerialRpcService to rpc : TestingRpcService in method public testHeartbeatTimeoutWithTaskManager() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest |
From |
To |
|
Change Variable Type rpc : TestingSerialRpcService to rpc : TestingRpcService in method public testTriggerRegistrationOnLeaderChange() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Change Variable Type rpc : TestingSerialRpcService to rpc : TestingRpcService in method public testSubmitTaskBeforeAcceptSlot() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Change Variable Type rpc : TestingSerialRpcService to rpc : TestingRpcService in method public testRejectAllocationRequestsForOutOfSyncSlots() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Change Variable Type rpc : TestingSerialRpcService to rpc : TestingRpcService in method public testImmediatelyRegistersIfLeaderIsKnown() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Change Variable Type rpcService : TestingSerialRpcService to rpcService : TestingRpcService in method public testHeartbeatTimeoutWithJobManager() : void in class org.apache.flink.runtime.clusterframework.ResourceManagerTest |
From |
To |
|
Change Variable Type rpc : TestingSerialRpcService to rpc : TestingRpcService in method public testJobLeaderDetection() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |
|
Change Variable Type rpcService : TestingSerialRpcService to rpcService : TestingRpcService in method public testHeartbeatTimeoutWithTaskExecutor() : void in class org.apache.flink.runtime.clusterframework.ResourceManagerTest |
From |
To |
|
Change Variable Type rpcService : TestingSerialRpcService to rpcService : TestingRpcService in method public testSlotAllocation() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorITCase |
From |
To |
|
Change Variable Type rpc : TestingSerialRpcService to rpc : TestingRpcService in method public testHeartbeatTimeoutWithResourceManager() : void in class org.apache.flink.runtime.jobmaster.JobMasterTest |
From |
To |
|
Change Variable Type rpc : TestingSerialRpcService to rpc : TestingRpcService in method public testSlotAcceptance() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest |
From |
To |