duplicated block id: 1 size: 76 cleaned lines of code in 2 files: - flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/InfluxDBSinkBuilder.java (52:218) - flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/InfluxDBSinkBuilder.java (52:218) duplicated block id: 2 size: 62 cleaned lines of code in 2 files: - flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/InfluxDBSinkOptions.java (27:99) - flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/InfluxDBSinkOptions.java (27:99) duplicated block id: 3 size: 58 cleaned lines of code in 2 files: - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduCatalog.java (232:326) - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/catalog/KuduDynamicCatalog.java (230:324) duplicated block id: 4 size: 42 cleaned lines of code in 2 files: - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduCatalog.java (101:166) - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/catalog/KuduDynamicCatalog.java (98:163) duplicated block id: 5 size: 37 cleaned lines of code in 2 files: - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduCatalog.java (171:223) - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/catalog/KuduDynamicCatalog.java (168:220) duplicated block id: 6 size: 17 cleaned lines of code in 2 files: - flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb/InfluxDBConfig.java (59:91) - flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb/InfluxDBConfig.java (241:273) duplicated block id: 7 size: 16 cleaned lines of code in 2 files: - flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/writer/InfluxDBWriter.java (51:68) - flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/writer/InfluxDBWriter.java (40:57) duplicated block id: 8 size: 10 cleaned lines of code in 2 files: - flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/InfluxDBSink.java (58:77) - flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/InfluxDBSink.java (30:50) duplicated block id: 9 size: 10 cleaned lines of code in 2 files: - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java (197:236) - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java (230:269) duplicated block id: 10 size: 10 cleaned lines of code in 2 files: - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java (137:173) - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java (194:230) duplicated block id: 11 size: 10 cleaned lines of code in 2 files: - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java (196:235) - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java (230:269) duplicated block id: 12 size: 10 cleaned lines of code in 2 files: - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java (196:235) - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java (197:236) duplicated block id: 13 size: 9 cleaned lines of code in 2 files: - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java (147:173) - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java (116:142) duplicated block id: 14 size: 9 cleaned lines of code in 2 files: - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java (116:142) - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java (204:230) duplicated block id: 15 size: 7 cleaned lines of code in 2 files: - flink-connector-akka/src/main/java/org/apache/flink/streaming/connectors/akka/utils/SubscribeReceiver.java (33:45) - flink-connector-akka/src/main/java/org/apache/flink/streaming/connectors/akka/utils/UnsubscribeReceiver.java (32:45) duplicated block id: 16 size: 7 cleaned lines of code in 2 files: - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader/KuduReader.java (83:91) - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/KuduWriter.java (76:84) duplicated block id: 17 size: 7 cleaned lines of code in 2 files: - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/KuduOutputFormat.java (81:92) - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/streaming/KuduSink.java (101:112) duplicated block id: 18 size: 7 cleaned lines of code in 2 files: - flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/StreamInMemOutputHandler.java (67:73) - flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/StreamOutputHandler.java (68:74) duplicated block id: 19 size: 7 cleaned lines of code in 2 files: - flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/HttpServer.scala (44:51) - flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/TcpServer.scala (52:60) duplicated block id: 20 size: 7 cleaned lines of code in 2 files: - flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/StreamInMemOutputHandler.java (89:98) - flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/StreamOutputHandler.java (90:99) duplicated block id: 21 size: 7 cleaned lines of code in 2 files: - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/KuduWriterConfig.java (163:169) - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/KuduWriterConfig.java (176:182) duplicated block id: 22 size: 6 cleaned lines of code in 2 files: - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/KuduTableInfo.java (112:118) - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/KuduWriterConfig.java (186:192) duplicated block id: 23 size: 6 cleaned lines of code in 2 files: - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java (98:103) - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java (101:106) duplicated block id: 24 size: 6 cleaned lines of code in 2 files: - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java (98:103) - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java (124:129) duplicated block id: 25 size: 6 cleaned lines of code in 2 files: - flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSink.java (149:154) - flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java (166:171) duplicated block id: 26 size: 6 cleaned lines of code in 2 files: - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java (101:106) - flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java (124:129) duplicated block id: 27 size: 6 cleaned lines of code in 2 files: - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader/KuduReader.java (171:178) - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/KuduWriter.java (117:124) duplicated block id: 28 size: 6 cleaned lines of code in 2 files: - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/KuduOutputFormat.java (45:52) - flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/streaming/KuduSink.java (49:55)