duplicated block id: 1 size: 14 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (286:299) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (344:357) duplicated block id: 2 size: 13 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (177:189) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (395:407) duplicated block id: 3 size: 13 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (340:352) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (413:425) duplicated block id: 4 size: 12 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (345:356) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (411:422) duplicated block id: 5 size: 11 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (345:355) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (450:460) duplicated block id: 6 size: 11 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (287:297) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (450:460) duplicated block id: 7 size: 11 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceBuilder.java (306:316) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java (578:588) duplicated block id: 8 size: 9 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceBuilder.java (278:290) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java (497:509) duplicated block id: 9 size: 9 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (309:318) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (327:336) duplicated block id: 10 size: 9 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (147:155) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (434:442) duplicated block id: 11 size: 8 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java (327:338) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java (367:378) duplicated block id: 12 size: 8 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSource.java (150:157) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSource.java (174:181) duplicated block id: 13 size: 8 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceBuilder.java (236:244) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java (466:474) duplicated block id: 14 size: 8 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (411:418) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (418:425) duplicated block id: 15 size: 7 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java (75:84) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (87:96) duplicated block id: 16 size: 7 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (401:408) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (567:574) duplicated block id: 17 size: 7 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java (63:72) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (87:96) duplicated block id: 18 size: 7 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java (101:107) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/enumerator/DynamicKafkaSourceEnumerator.java (124:130) duplicated block id: 19 size: 7 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java (234:240) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java (253:259) duplicated block id: 20 size: 7 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java (551:557) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java (592:598) duplicated block id: 21 size: 7 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java (75:84) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java (63:72) duplicated block id: 22 size: 7 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (122:130) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java (91:99) duplicated block id: 23 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (290:295) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (416:421) duplicated block id: 24 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java (50:56) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (312:318) duplicated block id: 25 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetFacet.java (43:49) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (90:96) duplicated block id: 26 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java (59:65) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (312:318) duplicated block id: 27 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (90:96) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (369:375) duplicated block id: 28 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (348:353) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (343:348) duplicated block id: 29 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetFacet.java (43:49) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 30 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/DynamicKafkaSourceBuilder.java (269:276) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java (488:495) duplicated block id: 31 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java (78:84) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java (59:65) duplicated block id: 32 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java (59:65) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java (50:56) duplicated block id: 33 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java (59:65) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 34 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java (66:72) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java (50:56) duplicated block id: 35 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java (78:84) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (312:318) duplicated block id: 36 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java (66:72) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetIdentifier.java (42:48) duplicated block id: 37 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetFacet.java (43:49) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetIdentifier.java (42:48) duplicated block id: 38 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java (71:77) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetIdentifier.java (42:48) duplicated block id: 39 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (90:96) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 40 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (290:295) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (343:348) duplicated block id: 41 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/ExactlyOnceKafkaWriter.java (191:197) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java (155:161) duplicated block id: 42 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetIdentifier.java (42:48) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java (50:56) duplicated block id: 43 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (398:403) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (437:442) duplicated block id: 44 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (90:96) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java (50:56) duplicated block id: 45 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java (122:127) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/DynamicKafkaRecordSerializationSchema.java (162:167) duplicated block id: 46 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetFacet.java (43:49) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java (50:56) duplicated block id: 47 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java (164:169) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java (222:227) duplicated block id: 48 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java (50:56) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (369:375) duplicated block id: 49 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (348:353) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (416:421) duplicated block id: 50 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (90:96) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (312:318) duplicated block id: 51 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java (75:81) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionFinished.java (56:62) duplicated block id: 52 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java (71:77) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 53 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (343:348) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (453:458) duplicated block id: 54 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java (59:65) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetFacet.java (43:49) duplicated block id: 55 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java (202:207) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java (217:222) duplicated block id: 56 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java (71:77) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java (66:72) duplicated block id: 57 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java (71:77) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java (59:65) duplicated block id: 58 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (416:421) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (453:458) duplicated block id: 59 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (180:185) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (437:442) duplicated block id: 60 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetFacet.java (43:49) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (369:375) duplicated block id: 61 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetIdentifier.java (42:48) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (90:96) duplicated block id: 62 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java (71:77) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (312:318) duplicated block id: 63 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java (66:72) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 64 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java (59:65) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (90:96) duplicated block id: 65 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java (71:77) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java (50:56) duplicated block id: 66 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java (66:72) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (312:318) duplicated block id: 67 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (421:427) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (463:469) duplicated block id: 68 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java (101:106) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java (118:123) duplicated block id: 69 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (150:155) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (398:403) duplicated block id: 70 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java (66:72) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (369:375) duplicated block id: 71 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java (71:77) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (369:375) duplicated block id: 72 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java (66:72) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetFacet.java (43:49) duplicated block id: 73 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java (71:77) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (90:96) duplicated block id: 74 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java (78:84) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java (50:56) duplicated block id: 75 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java (59:65) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/split/DynamicKafkaSourceSplit.java (66:72) duplicated block id: 76 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/CheckpointTransaction.java (50:56) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 77 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (369:375) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 78 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (421:427) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (437:443) duplicated block id: 79 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java (117:123) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java (139:146) duplicated block id: 80 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java (71:77) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetFacet.java (43:49) duplicated block id: 81 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/ClusterMetadata.java (71:77) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java (78:84) duplicated block id: 82 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (437:443) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (463:469) duplicated block id: 83 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java (69:76) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java (95:102) duplicated block id: 84 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (150:155) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (180:185) duplicated block id: 85 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetIdentifier.java (42:48) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 86 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (312:318) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (369:375) duplicated block id: 87 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (326:331) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (383:388) duplicated block id: 88 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetIdentifier.java (42:48) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (369:375) duplicated block id: 89 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java (59:65) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (369:375) duplicated block id: 90 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java (78:84) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetIdentifier.java (42:48) duplicated block id: 91 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetFacet.java (43:49) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (312:318) duplicated block id: 92 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java (358:365) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java (409:416) duplicated block id: 93 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/source/MetadataUpdateEvent.java (59:65) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetIdentifier.java (42:48) duplicated block id: 94 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetIdentifier.java (42:48) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (312:318) duplicated block id: 95 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java (78:84) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/DefaultKafkaDatasetFacet.java (43:49) duplicated block id: 96 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java (78:84) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 97 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/dynamic/metadata/KafkaStream.java (78:84) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (369:375) duplicated block id: 98 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (312:318) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 99 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (418:424) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (584:590)