duplicated block id: 1
size: 25 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java (219:250)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConnector.java (219:250)

duplicated block id: 2
size: 23 cleaned lines of code
in 2 files:
 - pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecordProcessor.java (52:80)
 - pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecordProcessor.java (54:82)

duplicated block id: 3
size: 22 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java (67:100)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConnector.java (67:100)

duplicated block id: 4
size: 21 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java (102:127)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConnector.java (102:127)

duplicated block id: 5
size: 15 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java (132:148)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConnector.java (132:148)

duplicated block id: 6
size: 11 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/text/HdfsAbstractTextFileSink.java (57:70)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/text/HdfsAbstractTextFileSink.java (57:70)

duplicated block id: 7
size: 10 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSyncThread.java (48:59)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsSyncThread.java (48:59)

duplicated block id: 8
size: 10 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsAbstractSink.java (78:90)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsAbstractSink.java (73:85)

duplicated block id: 9
size: 9 cleaned lines of code
in 2 files:
 - pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSource.java (132:142)
 - pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSource.java (123:133)

duplicated block id: 10
size: 9 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSyncThread.java (66:79)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsSyncThread.java (66:79)

duplicated block id: 11
size: 9 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsAbstractSequenceFileSink.java (68:78)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq/HdfsAbstractSequenceFileSink.java (68:78)

duplicated block id: 12
size: 7 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/SecurityUtil.java (48:57)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/SecurityUtil.java (48:57)

duplicated block id: 13
size: 7 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConfig.java (68:77)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConfig.java (68:77)

duplicated block id: 14
size: 6 cleaned lines of code
in 2 files:
 - pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSourceConfig.java (193:200)
 - pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java (225:232)

duplicated block id: 15
size: 6 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsAbstractSequenceFileSink.java (87:95)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq/HdfsAbstractSequenceFileSink.java (87:95)

duplicated block id: 16
size: 6 cleaned lines of code
in 2 files:
 - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java (189:198)
 - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConnector.java (189:198)

duplicated block id: 17
size: 6 cleaned lines of code
in 2 files:
 - pulsar-io/file/src/main/java/org/apache/pulsar/io/file/utils/GZipFiles.java (86:94)
 - pulsar-io/file/src/main/java/org/apache/pulsar/io/file/utils/ZipFiles.java (75:83)