|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeStartingNewPatternAfterMigrationSnapshot() : void in class org.apache.flink.cep.operator.CEPMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testCEPOperatorComparatorProcessTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testBucketStateTransitions() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testKeyedCEPOperatorCheckpointingWithRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testCEPOperatorComparatorEventTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testUDFReturningData() : void in class org.apache.flink.streaming.api.checkpoint.ListCheckpointedTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testRestoreStartingNewPatternAfterMigration() : void in class org.apache.flink.cep.operator.CEPMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testReaderSnapshotRestore() : void in class org.apache.flink.hdfstests.ContinuousFileProcessingTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testCheckpointRestore() : void in class org.apache.flink.streaming.api.functions.StatefulSequenceSourceTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testRestoreAfterBranchingPattern() : void in class org.apache.flink.cep.operator.CEPMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeSessionWindowsWithCountTriggerInMintConditionSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Change Variable Type latestSnapshot : OperatorStateHandles to latestSnapshot : OperatorSubtaskState in method public testDataDiscardingUponRestore() : void in class org.apache.flink.streaming.runtime.operators.WriteAheadSinkTestBase |
From |
To |
|
Change Variable Type snapshot2 : OperatorStateHandles to snapshot2 : OperatorSubtaskState in method public testKeyedCEPOperatorCheckpointingWithRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testKeyedCEPOperatorNFAUpdate() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method private testSlidingEventTimeWindows(operator OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type snapshot2 : OperatorStateHandles to snapshot2 : OperatorSubtaskState in method public testKeyedCEPOperatorCheckpointing() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type repackagedState : OperatorStateHandles to repackagedState : OperatorSubtaskState in method public testStateAndTimerStateShufflingScalingDown() : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testSessionWindowsWithContinuousEventTimeTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testScalingUp() : void in class org.apache.flink.streaming.runtime.operators.WriteAheadSinkTestBase |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method private testTumblingEventTimeWindows(operator OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type mergedSnapshot : OperatorStateHandles to mergedSnapshot : OperatorSubtaskState in method public testScaleDown() : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithNonKeyedOperatorTest |
From |
To |
|
Change Variable Type mergedSnapshot : OperatorStateHandles to mergedSnapshot : OperatorSubtaskState in method public testScalingDown() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testSessionWindowsWithProcessFunction() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeAfterBranchingPatternSnapshot() : void in class org.apache.flink.cep.operator.CEPMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testSnapshotAndRestore() : void in class org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeAndOrSubtypConditionsPatternAfterMigrationSnapshot() : void in class org.apache.flink.cep.operator.CEPMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeSessionWindowsWithCountTriggerSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testSnapshotAndRestore() : void in class org.apache.flink.streaming.api.operators.KeyedProcessOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeSinglePatternAfterMigrationSnapshot() : void in class org.apache.flink.cep.operator.CEPMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testRestartWithFullQueue() : void in class org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testStateAndTimerStateShufflingScalingUp() : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testReduceSessionWindowsWithProcessFunction() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testSessionWindowsWithCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testStateSnapshotAndRestore() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorContractTest |
From |
To |
|
Change Variable Type mergedState : OperatorStateHandles to mergedState : OperatorSubtaskState in method private testRescaling(initialParallelism int, numPartitions int, restoredParallelism int, restoredNumPartitions int) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testCEPFunctionScalingDown() : void in class org.apache.flink.cep.operator.CEPRescalingTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testLogTimeoutAlmostReachedWarningDuringRecovery() : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeWindowsWithKryoSerializedKeysSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Change Variable Type snapshot1 : OperatorStateHandles to snapshot1 : OperatorSubtaskState in method public testScalingDown() : void in class org.apache.flink.streaming.runtime.operators.WriteAheadSinkTestBase |
From |
To |
|
Change Variable Type mergedState : OperatorStateHandles to mergedState : OperatorSubtaskState in method public testReaderScalingDown() : void in class org.apache.flink.streaming.runtime.operators.ContinuousFileProcessingRescalingTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeMonitoringSourceSnapshot() : void in class org.apache.flink.hdfstests.ContinuousFileProcessingMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method private writeSnapshot(path String, state HashMap<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testReduceSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type snapshot1 : OperatorStateHandles to snapshot1 : OperatorSubtaskState in method public testFailBeforeNotifyAndResumeWorkAfterwards() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase |
From |
To |
|
Change Variable Type mergedSnapshot : OperatorStateHandles to mergedSnapshot : OperatorSubtaskState in method public testScalingUp() : void in class org.apache.flink.streaming.connectors.fs.RollingSinkITCase |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testRestoreToCheckpointAfterExceedingProducersPool() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testCEPFunctionScalingUp() : void in class org.apache.flink.cep.operator.CEPRescalingTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method private repartitionAndExecute(topic String, inputStates List<OperatorStateHandle>, parallelism int, maxParallelism int, inputData Iterator<Integer>) : List<OperatorStateHandle> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase |
From |
To |
|
Change Variable Type mergedSnapshot : OperatorStateHandles to mergedSnapshot : OperatorSubtaskState in method public testScalingDown() : void in class org.apache.flink.streaming.runtime.operators.WriteAheadSinkTestBase |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeApplyEventTimeWindowsSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testKeyedCEPOperatorCheckpointing() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type mergedSnapshot : OperatorStateHandles to mergedSnapshot : OperatorSubtaskState in method public testScaleUp() : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeReaderSnapshot() : void in class org.apache.flink.hdfstests.ContinuousFileProcessingMigrationTest |
From |
To |
|
Change Variable Type checkpoint0 : OperatorStateHandles to checkpoint0 : OperatorSubtaskState in method public testRecoverCommittedTransaction() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeReducingProcessingTimeWindowsSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method private writeSnapshot(path String, state HashMap<StreamShardMetadata,SequenceNumber>) : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerMigrationTest |
From |
To |
|
Change Variable Type mergedSnapshot : OperatorStateHandles to mergedSnapshot : OperatorSubtaskState in method public testSameParallelismWithShufflingStates() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testCEPOperatorCleanupEventTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testPointSessions() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeReducingEventTimeWindowsSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testKeyedCEPOperatorNFAUpdateWithRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type stateHandles : OperatorStateHandles to stateHandles : OperatorSubtaskState in method public testPojoSerializerUpgrade(classSourceA String, classSourceB String, hasBField boolean, isKeyedState boolean) : void in class org.apache.flink.test.typeserializerupgrade.PojoSerializerUpgradeTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeApplyProcessingTimeWindowsSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testReaderScalingUp() : void in class org.apache.flink.streaming.runtime.operators.ContinuousFileProcessingRescalingTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testFailBeforeNotify() : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testFlinkKafkaProducer011FailBeforeNotify() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase |
From |
To |
|
Change Variable Type handle : OperatorStateHandles to handle : OperatorSubtaskState in method public repackageState(handles OperatorSubtaskState...) : OperatorSubtaskState in class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testUDFReturningNull() : void in class org.apache.flink.streaming.api.checkpoint.ListCheckpointedTest |
From |
To |
|
Change Variable Type snapshot2 : OperatorStateHandles to snapshot2 : OperatorSubtaskState in method public testKeyedCEPOperatorNFAUpdate() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type mergedSnapshot : OperatorStateHandles to mergedSnapshot : OperatorSubtaskState in method public testScalingUp() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Change Variable Type mergedSnapshot : OperatorStateHandles to mergedSnapshot : OperatorSubtaskState in method public testScaleDown() : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperatorTest |
From |
To |
|
Change Variable Type snapshot1 : OperatorStateHandles to snapshot1 : OperatorSubtaskState in method public testFailAndRecoverSameCheckpointTwice() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase |
From |
To |
|
Change Variable Type snapshot2 : OperatorStateHandles to snapshot2 : OperatorSubtaskState in method public testKeyedCEPOperatorNFAUpdateWithRocksDB() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type handles : OperatorStateHandles to handles : OperatorSubtaskState in method public testCheckpointAndRestore() : void in class org.apache.flink.streaming.api.functions.FromElementsFunctionTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testFunctionRestore() : void in class org.apache.flink.hdfstests.ContinuousFileProcessingTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testSnapshotAndRestoreWrappedCheckpointedFunction() : void in class org.apache.flink.streaming.api.operators.WrappingFunctionSnapshotRestoreTest |
From |
To |
|
Change Variable Type mergedSnapshot : OperatorStateHandles to mergedSnapshot : OperatorSubtaskState in method public testScalingDown() : void in class org.apache.flink.streaming.connectors.fs.RollingSinkITCase |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testIgnoreCommitExceptionDuringRecovery() : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public writeSnapshot() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkMigrationTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testBucketStateTransitions() : void in class org.apache.flink.streaming.connectors.fs.RollingSinkITCase |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testSnapshotAndRestoreWrappedListCheckpointed() : void in class org.apache.flink.streaming.api.operators.WrappingFunctionSnapshotRestoreTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testUDFReturningEmpty() : void in class org.apache.flink.streaming.api.checkpoint.ListCheckpointedTest |
From |
To |
|
Change Variable Type handles : OperatorStateHandles to handles : OperatorSubtaskState in method public testOperatorStatesSnapshotRestore() : void in class org.apache.flink.streaming.api.operators.StreamOperatorSnapshotRestoreTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testFlinkKafkaProducer011FailTransactionCoordinatorBeforeNotify() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase |
From |
To |
|
Change Variable Type snapshot2 : OperatorStateHandles to snapshot2 : OperatorSubtaskState in method public testScalingDown() : void in class org.apache.flink.streaming.runtime.operators.WriteAheadSinkTestBase |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testEnsureProcessingTimeTimerRegisteredOnRestore() : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperatorTest |
From |
To |
|
Change Variable Type snapshot : OperatorStateHandles to snapshot : OperatorSubtaskState in method public testCEPOperatorCleanupProcessingTime() : void in class org.apache.flink.cep.operator.CEPOperatorTest |
From |
To |
|
Change Variable Type mergedSnapshot : OperatorStateHandles to mergedSnapshot : OperatorSubtaskState in method public testScaleUp() : void in class org.apache.flink.streaming.api.operators.co.CoBroadcastWithNonKeyedOperatorTest |
From |
To |
|
Change Variable Type data : OperatorStateHandles to data : OperatorSubtaskState in method public testCheckpointing() : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest |
From |
To |