|
Change Variable Type operatorSnapshotResult3 : OperatorSnapshotResult to operatorSnapshotResult3 : OperatorSnapshotFutures in method public testFailingAsyncCheckpointRunnable() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Change Variable Type operatorStateResult : OperatorSnapshotResult to operatorStateResult : OperatorSnapshotFutures in method public snapshot(checkpointId long, timestamp long) : OperatorSubtaskState in class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Change Variable Type operatorSnapshotResult : OperatorSnapshotResult to operatorSnapshotResult : OperatorSnapshotFutures in method public executeCheckpointing() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.CheckpointingOperation |
From |
To |
|
Change Variable Type operatorSnapshotResult : OperatorSnapshotResult to operatorSnapshotResult : OperatorSnapshotFutures in method public testAsyncCheckpointingConcurrentCloseAfterAcknowledge() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Change Variable Type entry : Map.Entry<OperatorID,OperatorSnapshotResult> to entry : Map.Entry<OperatorID,OperatorSnapshotFutures> in method public run() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable |
From |
To |
|
Change Variable Type operatorSnapshotResult : OperatorSnapshotResult to operatorSnapshotResult : OperatorSnapshotFutures in method private cleanup() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable |
From |
To |
|
Change Variable Type operatorSnapshotResult : OperatorSnapshotResult to operatorSnapshotResult : OperatorSnapshotFutures in method public testFailingBackendSnapshotMethod() : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperatorTest |
From |
To |
|
Change Variable Type statelessOperatorSnapshotResult : OperatorSnapshotResult to statelessOperatorSnapshotResult : OperatorSnapshotFutures in method public testEmptySubtaskStateLeadsToStatelessAcknowledgment() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Change Variable Type operatorSnapshotResult : OperatorSnapshotResult to operatorSnapshotResult : OperatorSnapshotFutures in method public testCancelAndCleanup() : void in class org.apache.flink.streaming.api.operators.OperatorSnapshotFuturesTest |
From |
To |
|
Change Variable Type operatorSnapshotResult2 : OperatorSnapshotResult to operatorSnapshotResult2 : OperatorSnapshotFutures in method public testFailingAsyncCheckpointRunnable() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Change Variable Type snapshotInProgress : OperatorSnapshotResult to snapshotInProgress : OperatorSnapshotFutures in method private checkpointStreamOperator(op StreamOperator<?>) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.CheckpointingOperation |
From |
To |
|
Change Variable Type snapshotInProgress : OperatorSnapshotResult to snapshotInProgress : OperatorSnapshotFutures in method public snapshotState(checkpointId long, timestamp long, checkpointOptions CheckpointOptions, factory CheckpointStreamFactory) : OperatorSnapshotFutures in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Variable Type operatorSnapshotResult : OperatorSnapshotResult to operatorSnapshotResult : OperatorSnapshotFutures in method public testAsyncCheckpointingConcurrentCloseBeforeAcknowledge() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Change Variable Type snapshotInProgress : OperatorSnapshotResult to snapshotInProgress : OperatorSnapshotFutures in method public run() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable |
From |
To |
|
Change Variable Type operatorSnapshotResult2 : OperatorSnapshotResult to operatorSnapshotResult2 : OperatorSnapshotFutures in method public testFailingCheckpointStreamOperator() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Change Variable Type operatorSnapshotResult1 : OperatorSnapshotResult to operatorSnapshotResult1 : OperatorSnapshotFutures in method public testFailingAsyncCheckpointRunnable() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Change Variable Type operatorSnapshotResult1 : OperatorSnapshotResult to operatorSnapshotResult1 : OperatorSnapshotFutures in method public testFailingCheckpointStreamOperator() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |