originalPartitions = Arrays.asList(new KafkaTopicPartition(testTopic,7),new KafkaTopicPartition(testTopic,13),new KafkaTopicPartition(testTopic,21)) | originalPartitions = new HashMap<>() | Arrays.asList(new KafkaTopicPartition(testTopic,7),new KafkaTopicPartition(testTopic,13),new KafkaTopicPartition(testTopic,21)) | new HashMap<>() | flink | ed68fedbe90db03823d75a020510ad3c344fa73e | org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcherTimestampsTest | | _1 | originalPartitions |
---|
_2 | originalPartitions |
---|
| xyz | Arrays.asList(new KafkaTopicPartition(testTopic,7),new KafkaTopicPartition(testTopic,13),new KafkaTopicPartition(testTopic,21)) |
---|
| - java.util.HashMap
- java.util.Arrays
| | AssignedTo | False |
originalPartitions = Arrays.asList(new KafkaTopicPartition(testTopic,7),new KafkaTopicPartition(testTopic,13),new KafkaTopicPartition(testTopic,21)) | originalPartitions = new HashMap<>() | Arrays.asList(new KafkaTopicPartition(testTopic,7),new KafkaTopicPartition(testTopic,13),new KafkaTopicPartition(testTopic,21)) | new HashMap<>() | flink | ed68fedbe90db03823d75a020510ad3c344fa73e | org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcherTimestampsTest | | _1 | originalPartitions |
---|
_2 | originalPartitions |
---|
| xyz | Arrays.asList(new KafkaTopicPartition(testTopic,7),new KafkaTopicPartition(testTopic,13),new KafkaTopicPartition(testTopic,21)) |
---|
| - java.util.HashMap
- java.util.Arrays
| | AssignedTo | False |