duplicated block id: 1 size: 14 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model/KinesisStreamShard.java (57:81) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model/StreamShardHandle.java (50:74) duplicated block id: 2 size: 7 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisOptions.java (150:158) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisOptions.java (170:178) duplicated block id: 3 size: 7 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/KinesisDataFetcher.java (563:569) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/KinesisDataFetcher.java (672:678) duplicated block id: 4 size: 6 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/AdaptivePollingRecordPublisher.java (53:58) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/PollingRecordPublisher.java (81:86) duplicated block id: 5 size: 6 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FixedKinesisPartitioner.java (61:67) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisDynamicSink.java (141:147) duplicated block id: 6 size: 6 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/DynamoDBStreamsDataFetcher.java (79:84) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/KinesisDataFetcher.java (382:387) duplicated block id: 7 size: 6 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisDynamicSink.java (141:147) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisDynamicSource.java (133:139) duplicated block id: 8 size: 6 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FlinkDynamoDBStreamsConsumer.java (72:77) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FlinkKinesisConsumer.java (466:471) duplicated block id: 9 size: 6 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisDynamicSink.java (141:147) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/RowDataFieldsKinesisPartitioner.java (250:256) duplicated block id: 10 size: 6 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FixedKinesisPartitioner.java (61:67) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/RowDataFieldsKinesisPartitioner.java (250:256) duplicated block id: 11 size: 6 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisDynamicSource.java (133:139) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/RowDataFieldsKinesisPartitioner.java (250:256) duplicated block id: 12 size: 6 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/FixedKinesisPartitioner.java (61:67) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisDynamicSource.java (133:139) duplicated block id: 13 size: 6 cleaned lines of code in 2 files: - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/PollingRecordPublisherFactory.java (75:80) - amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling/PollingRecordPublisherFactory.java (83:88)