|
Change Variable Type expected : Set<Tuple2<KafkaTopicPartition,Long>> to expected : Set<Serializable> in method public checkRestoredCheckpointWhenFetcherNotReady() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest |
From |
To |
|
Change Variable Type expectedState : TestingListState<Tuple2<KafkaTopicPartition,Long>> to expectedState : TestingListState<Serializable> in method public checkRestoredCheckpointWhenFetcherNotReady() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest |
From |
To |
|
Change Variable Type listState2 : TestingListState<Tuple2<KafkaTopicPartition,Long>> to listState2 : TestingListState<Serializable> in method public testSnapshotState() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest |
From |
To |
|
Change Variable Type kafkaTopicPartitionLongTuple2 : Tuple2<KafkaTopicPartition,Long> to serializable : Serializable in method public checkRestoredCheckpointWhenFetcherNotReady() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest |
From |
To |
|
Change Variable Type listState : TestingListState<Tuple2<KafkaTopicPartition,Long>> to listState : TestingListState<Serializable> in method public checkRestoredCheckpointWhenFetcherNotReady() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest |
From |
To |
|
Change Variable Type listState : TestingListState<Tuple2<KafkaTopicPartition,Long>> to listState : TestingListState<Serializable> in method public checkRestoredNullCheckpointWhenFetcherNotReady() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest |
From |
To |
|
Change Variable Type listState3 : TestingListState<Tuple2<KafkaTopicPartition,Long>> to listState3 : TestingListState<Serializable> in method public testSnapshotState() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest |
From |
To |
|
Change Variable Type kafkaTopicPartitionLongTuple2 : Tuple2<KafkaTopicPartition,Long> to serializable : Serializable in method public testSnapshotState() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest |
From |
To |
|
Change Variable Type listState1 : TestingListState<Tuple2<KafkaTopicPartition,Long>> to listState1 : TestingListState<Serializable> in method public testSnapshotState() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest |
From |
To |