duplicated block id: 1 size: 25 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java (213:240) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java (320:347) duplicated block id: 2 size: 20 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (692:716) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java (154:178) duplicated block id: 3 size: 20 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (809:832) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java (266:289) duplicated block id: 4 size: 13 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (268:280) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (323:335) duplicated block id: 5 size: 13 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (175:187) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (383:395) duplicated block id: 6 size: 13 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (331:343) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (400:412) duplicated block id: 7 size: 12 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaFetcher.java (79:90) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaShuffleFetcher.java (61:72) duplicated block id: 8 size: 12 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1471:1489) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java (415:433) duplicated block id: 9 size: 12 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java (255:266) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java (77:88) duplicated block id: 10 size: 12 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java (245:259) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java (367:381) duplicated block id: 11 size: 11 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (336:346) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (400:410) duplicated block id: 12 size: 11 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java (239:252) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java (62:74) duplicated block id: 13 size: 11 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java (353:368) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java (431:446) duplicated block id: 14 size: 10 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (269:278) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (434:443) duplicated block id: 15 size: 10 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (324:333) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (434:443) duplicated block id: 16 size: 10 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java (342:351) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java (284:293) duplicated block id: 17 size: 9 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java (298:306) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java (202:210) duplicated block id: 18 size: 9 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (297:306) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (315:324) duplicated block id: 19 size: 8 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java (272:285) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java (390:403) duplicated block id: 20 size: 8 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java (301:312) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java (341:352) duplicated block id: 21 size: 8 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaFetcher.java (92:99) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaShuffleFetcher.java (76:83) duplicated block id: 22 size: 8 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (400:407) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (405:412) duplicated block id: 23 size: 8 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (140:147) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (420:427) duplicated block id: 24 size: 7 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java (175:182) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java (199:206) duplicated block id: 25 size: 7 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java (119:127) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java (88:96) duplicated block id: 26 size: 7 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (379:386) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (559:566) duplicated block id: 27 size: 7 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java (232:238) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java (251:257) duplicated block id: 28 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: 29 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java (35:41) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1555:1561) duplicated block id: 30 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1654:1663) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1757:1766) duplicated block id: 31 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1602:1608) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 32 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (86:92) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1555:1561) duplicated block id: 33 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1555:1561) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1845:1851) duplicated block id: 34 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java (317:322) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java (333:338) duplicated block id: 35 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1602:1608) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (359:365) duplicated block id: 36 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1457:1466) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java (400:409) duplicated block id: 37 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (359:365) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 38 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (86:92) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (359:365) 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 (86:92) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1602:1608) 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/internals/KafkaConsumerThread.java (308:318) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaConsumerThread.java (348:357) 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/KafkaWriterState.java (35:41) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 42 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (86:92) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (292:298) 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/FlinkKafkaProducer.java (1555:1561) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (359:365) 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/KafkaWriterState.java (35:41) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (292:298) duplicated block id: 45 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java (35:41) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1602:1608) duplicated block id: 46 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1845:1851) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (292:298) 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/FlinkKafkaProducer.java (1602:1608) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (292:298) duplicated block id: 48 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java (357:364) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java (408:415) 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/FlinkKafkaProducer.java (1555:1561) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (292:298) duplicated block id: 50 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java (68:75) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java (95:102) duplicated block id: 51 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1845:1851) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (359:365) duplicated block id: 52 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (471:502) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (510:545) 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/internals/ClosableBlockingQueue.java (263:270) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java (294:301) duplicated block id: 54 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (292:298) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (359:365) duplicated block id: 55 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (86:92) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java (35:41) duplicated block id: 56 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java (344:352) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java (390:398) duplicated block id: 57 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1555:1561) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 58 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (86:92) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 59 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java (35:41) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java (359:365) duplicated block id: 60 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java (234:241) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java (263:270) duplicated block id: 61 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java (177:182) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java (192:197) duplicated block id: 62 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java (102:107) - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java (116:121) duplicated block id: 63 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: 64 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1555:1561) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1602:1608) duplicated block id: 65 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java (234:241) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java (294:301) duplicated block id: 66 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommittable.java (86:92) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1845:1851) 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 (401:407) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (427:433) duplicated block id: 68 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1845:1851) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) 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/FlinkKafkaProducer.java (1602:1608) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1845:1851) duplicated block id: 70 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java (292:298) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/SinkBufferFlushMode.java (64:70) duplicated block id: 71 size: 6 cleaned lines of code in 2 files: - flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java (35:41) - flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1845:1851)