|
Change Variable Type snapshot2 : StreamStateHandle to snapshot2 : OperatorStateHandles in method public testKeyedCEPOperatorCheckpointingWithRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type snapshot2 : StreamStateHandle to snapshot2 : OperatorStateHandles in method public testKeyedCEPOperatorCheckpointing() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method public testKeyedCEPOperatorCheckpointing() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method public testKeyedCEPOperatorCheckpointingWithRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type service : HeapInternalTimerService<?,?> to timeServiceManager : InternalTimeServiceManager<?,?> in method public processWatermark(mark Watermark) : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |