duplicated block id: 1 size: 18 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarClientFactory.java (129:146) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarClientFactory.java (201:218) duplicated block id: 2 size: 11 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/PulsarSinkOptions.java (272:282) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java (506:516) duplicated block id: 3 size: 8 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/SinkConfiguration.java (134:143) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java (212:221) duplicated block id: 4 size: 7 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/AvroSchemaFactory.java (53:59) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/JSONSchemaFactory.java (46:52) duplicated block id: 5 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer/PulsarCommittable.java (50:56) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java (212:218) duplicated block id: 6 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer/PulsarCommittable.java (50:56) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicRange.java (87:93) duplicated block id: 7 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicRange.java (87:93) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplit.java (101:107) duplicated block id: 8 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer/PulsarCommittable.java (50:56) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicPartition.java (153:159) duplicated block id: 9 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer/PulsarCommittable.java (50:56) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/SinkConfiguration.java (134:140) duplicated block id: 10 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java (72:77) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java (90:95) duplicated block id: 11 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicPartition.java (153:159) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplit.java (101:107) duplicated block id: 12 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/SinkConfiguration.java (134:140) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicPartition.java (153:159) duplicated block id: 13 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer/PulsarCommittable.java (50:56) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplit.java (101:107) duplicated block id: 14 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchema.java (197:203) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/SinkConfiguration.java (134:140) duplicated block id: 15 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/SinkConfiguration.java (134:140) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplit.java (101:107) duplicated block id: 16 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchema.java (197:203) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java (212:218) duplicated block id: 17 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchema.java (197:203) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicPartition.java (153:159) duplicated block id: 18 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchema.java (197:203) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer/PulsarCommittable.java (50:56) duplicated block id: 19 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicPartition.java (153:159) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicRange.java (87:93) duplicated block id: 20 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java (212:218) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicRange.java (87:93) duplicated block id: 21 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/SinkConfiguration.java (134:140) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicRange.java (87:93) duplicated block id: 22 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/KeyHashTopicRouter.java (52:57) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/RoundRobinTopicRouter.java (53:58) duplicated block id: 23 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java (212:218) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplit.java (101:107) duplicated block id: 24 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchema.java (197:203) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplit.java (101:107) duplicated block id: 25 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/PulsarSinkOptions.java (113:118) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java (194:199) duplicated block id: 26 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java (145:150) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java (160:165) duplicated block id: 27 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java (212:218) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicPartition.java (153:159) duplicated block id: 28 size: 6 cleaned lines of code in 2 files: - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchema.java (197:203) - flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicRange.java (87:93)