|
Move Method private waitForMarkerFiles(basedir File, num int, timeout long) : void from class org.apache.flink.test.recovery.ProcessFailureBatchRecoveryITCase to protected waitForMarkerFiles(basedir File, num int, timeout long) : void from class org.apache.flink.test.util.ProcessFailureRecoveryTestBase |
From |
To |
|
Move Method private createTempDirectory() : File from class org.apache.flink.test.recovery.ProcessFailureBatchRecoveryITCase to protected createTempDirectory() : File from class org.apache.flink.test.util.ProcessFailureRecoveryTestBase |
From |
To |
|
Move Method public testTaskManagerProcessFailure() : void from class org.apache.flink.test.recovery.ProcessFailureBatchRecoveryITCase to public testTaskManagerProcessFailure() : void from class org.apache.flink.test.util.ProcessFailureRecoveryTestBase |
From |
To |
|
Move Method private printProcessLog(processName String, log String) : void from class org.apache.flink.test.recovery.ProcessFailureBatchRecoveryITCase to protected printProcessLog(processName String, log String) : void from class org.apache.flink.test.util.ProcessFailureRecoveryTestBase |
From |
To |
|
Move Method private touchFile(file File) : void from class org.apache.flink.test.recovery.ProcessFailureBatchRecoveryITCase to protected touchFile(file File) : void from class org.apache.flink.test.util.ProcessFailureRecoveryTestBase |
From |
To |
|
Move Method private waitUntilNumTaskManagersAreRegistered(jobManager ActorRef, numExpected int, maxDelay long) : void from class org.apache.flink.test.recovery.ProcessFailureBatchRecoveryITCase to protected waitUntilNumTaskManagersAreRegistered(jobManager ActorRef, numExpected int, maxDelay long) : void from class org.apache.flink.test.util.ProcessFailureRecoveryTestBase |
From |
To |