duplicated block id: 1 size: 108 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java (51:248) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConnector.java (51:248) duplicated block id: 2 size: 35 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsAbstractSequenceFileSink.java (45:94) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq/HdfsAbstractSequenceFileSink.java (45:94) duplicated block id: 3 size: 30 cleaned lines of code in 2 files: - pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java (87:118) - pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSourceConfig.java (52:83) duplicated block id: 4 size: 29 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSyncThread.java (34:77) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsSyncThread.java (34:77) duplicated block id: 5 size: 29 cleaned lines of code in 2 files: - pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java (137:169) - pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSourceConfig.java (102:134) duplicated block id: 6 size: 26 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/text/HdfsAbstractTextFileSink.java (39:76) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/text/HdfsAbstractTextFileSink.java (39:76) duplicated block id: 7 size: 22 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsSequentialTextSink.java (39:69) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq/HdfsSequentialTextSink.java (39:69) duplicated block id: 8 size: 21 cleaned lines of code in 2 files: - pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecordProcessor.java (55:85) - pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecordProcessor.java (53:83) duplicated block id: 9 size: 18 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/SecurityUtil.java (31:89) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/SecurityUtil.java (31:89) duplicated block id: 10 size: 16 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsAbstractSink.java (67:88) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsAbstractSink.java (62:83) duplicated block id: 11 size: 16 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConfig.java (31:75) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConfig.java (31:75) duplicated block id: 12 size: 16 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSinkConfig.java (86:109) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsSinkConfig.java (76:99) duplicated block id: 13 size: 15 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsTextSink.java (33:52) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq/HdfsTextSink.java (33:52) duplicated block id: 14 size: 14 cleaned lines of code in 2 files: - pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBSinkConfig.java (102:120) - pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSinkConfig.java (96:114) duplicated block id: 15 size: 14 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/HdfsResources.java (28:49) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/HdfsResources.java (28:49) duplicated block id: 16 size: 12 cleaned lines of code in 2 files: - pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSinkConfig.java (37:49) - pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java (37:49) duplicated block id: 17 size: 11 cleaned lines of code in 2 files: - pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java (55:67) - pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/BaseKinesisConfig.java (38:50) duplicated block id: 18 size: 11 cleaned lines of code in 2 files: - pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBSinkConfig.java (36:49) - pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSinkConfig.java (37:50) duplicated block id: 19 size: 10 cleaned lines of code in 2 files: - pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java (300:310) - pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java (346:356) duplicated block id: 20 size: 10 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSinkConfig.java (41:76) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsSinkConfig.java (39:74) duplicated block id: 21 size: 10 cleaned lines of code in 2 files: - pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileRecord.java (58:73) - pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecord.java (74:89) duplicated block id: 22 size: 9 cleaned lines of code in 2 files: - pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data/TweetData.java (37:45) - pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data/TweetData.java (101:109) duplicated block id: 23 size: 9 cleaned lines of code in 2 files: - pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBSinkConfig.java (90:99) - pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSinkConfig.java (84:93) duplicated block id: 24 size: 8 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsAbstractSink.java (98:107) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsAbstractSink.java (99:108) duplicated block id: 25 size: 8 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsAbstractSink.java (55:63) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsAbstractSink.java (53:61) duplicated block id: 26 size: 7 cleaned lines of code in 2 files: - pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSource.java (124:131) - pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSource.java (133:140) duplicated block id: 27 size: 7 cleaned lines of code in 2 files: - pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java (78:85) - pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/BaseKinesisConfig.java (61:68) duplicated block id: 28 size: 7 cleaned lines of code in 2 files: - pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSinkConfig.java (63:69) - pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java (79:85) duplicated block id: 29 size: 7 cleaned lines of code in 2 files: - pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data/TweetData.java (29:35) - pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data/TweetData.java (94:100) duplicated block id: 30 size: 7 cleaned lines of code in 2 files: - pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBSinkConfig.java (78:85) - pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSinkConfig.java (78:85) duplicated block id: 31 size: 6 cleaned lines of code in 2 files: - pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsAbstractSink.java (46:52) - pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsAbstractSink.java (45:51) duplicated block id: 32 size: 6 cleaned lines of code in 2 files: - pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java (156:163) - pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java (119:126) duplicated block id: 33 size: 6 cleaned lines of code in 2 files: - pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java (427:433) - pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java (458:464) duplicated block id: 34 size: 6 cleaned lines of code in 2 files: - pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java (89:95) - pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java (76:82) duplicated block id: 35 size: 6 cleaned lines of code in 2 files: - pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java (194:199) - pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java (241:246) duplicated block id: 36 size: 6 cleaned lines of code in 2 files: - pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java (222:230) - pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSourceConfig.java (190:198) duplicated block id: 37 size: 6 cleaned lines of code in 2 files: - pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQAbstractConfig.java (79:85) - pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSourceConfig.java (43:49) duplicated block id: 38 size: 6 cleaned lines of code in 2 files: - pulsar-io/file/src/main/java/org/apache/pulsar/io/file/utils/GZipFiles.java (83:90) - pulsar-io/file/src/main/java/org/apache/pulsar/io/file/utils/ZipFiles.java (72:79) duplicated block id: 39 size: 6 cleaned lines of code in 2 files: - pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java (129:135) - pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSourceConfig.java (94:100) duplicated block id: 40 size: 6 cleaned lines of code in 2 files: - pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchConfig.java (83:89) - pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBSinkConfig.java (54:60)