|
Change Return Type SavepointV1 to SavepointV2 in method public deserialize(dis DataInputStream, cl ClassLoader) : SavepointV2 in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1Serializer |
From |
To |
|
Change Return Type SavepointV1 to SavepointV2 in method private convertSavepoint(taskStates List<TaskState>, userClassLoader ClassLoader, checkpointID long) : SavepointV2 in class org.apache.flink.migration.runtime.checkpoint.savepoint.SavepointV0Serializer |
From |
To |
|
Change Return Type ConcurrentLinkedQueue<Object> to LinkedBlockingQueue<Object> in method public getOutput() : LinkedBlockingQueue<Object> in class org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness |
From |
To |
|
Change Return Type SavepointV1 to SavepointV2 in method public deserialize(dis DataInputStream, userClassLoader ClassLoader) : SavepointV2 in class org.apache.flink.migration.runtime.checkpoint.savepoint.SavepointV0Serializer |
From |
To |
|
Change Variable Type actual : Savepoint to actual : SavepointV2 in method public testSerializeDeserializeV1() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV1SerializerTest |
From |
To |
|
Change Variable Type savepoint : SavepointV1 to savepoint : SavepointV2 in method public testLoadAndValidateSavepoint() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointLoaderTest |
From |
To |
|
Change Variable Type stored : SavepointV1 to stored : SavepointV2 in method public testStoreLoadDispose() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStoreTest |
From |
To |
|
Change Variable Type savepoint : SavepointV1 to savepoint : SavepointV2 in method public testTriggerSavepointAndResumeWithFileBasedCheckpoints() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type savepoint : SavepointV1 to savepoint : SavepointV2 in method public testStoreExternalizedCheckpointsToSameDirectory() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointStoreTest |
From |
To |
|
Change Variable Type savepoint : SavepointV1 to checkpoint : SavepointV2 in method public testSavepointV1() : void in class org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Test |
From |
To |