|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testFailBeforeNotifyAndResumeWorkAfterwards() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testRestoreToCheckpointAfterExceedingProducersPool() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testScaleDownBeforeFirstCheckpoint() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testFailBeforeNotifyAndResumeWorkAfterwards() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testFailAndRecoverSameCheckpointTwice() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testFlinkKafkaProducer011FailTransactionCoordinatorBeforeNotify() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testMigrateFromAtLeastOnceToExactlyOnce() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testRestoreToCheckpointAfterExceedingProducersPool() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testMigrateFromAtExactlyOnceToAtLeastOnce() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testMigrateFromAtLeastOnceToExactlyOnce() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testFailAndRecoverSameCheckpointTwice() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testScaleDownBeforeFirstCheckpoint() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testFlinkKafkaProducer011FailBeforeNotify() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testRecoverCommittedTransaction() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testFlinkKafkaProducerFailBeforeNotify() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testMigrateFromAtExactlyOnceToAtLeastOnce() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |
|
Extract And Move Method protected assertExactlyOnceForTopic(properties Properties, topic String, partition int, expectedElements List<Integer>) : void extracted from public testRecoverCommittedTransaction() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011ITCase & moved to class org.apache.flink.streaming.connectors.kafka.KafkaTestBase |
From |
To |