45 duplicated lines in:
  - integrations/flink_connector/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java (87:155, 51%)
  - integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java (92:160, 50%)

44 duplicated lines in:
  - integrations/flink_connector/src/main/java/com/amazonaws/services/timestream/TimestreamPoint.java (8:96, 100%)
  - integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamPoint.java (8:96, 100%)

37 duplicated lines in:
  - integrations/flink_connector/src/main/java/com/amazonaws/services/timestream/TimestreamInitializer.java (11:56, 100%)
  - integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamInitializer.java (11:56, 100%)

36 duplicated lines in:
  - integrations/flink_connector/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java (28:76, 40%)
  - integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java (28:76, 40%)

24 duplicated lines in:
  - integrations/flink_connector/src/main/java/com/amazonaws/services/kinesisanalytics/operators/JsonToTimestreamPayloadFn.java (21:49, 77%)
  - integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamPointSchema.java (43:71, 66%)

12 duplicated lines in:
  - integrations/flink_connector/src/main/java/com/amazonaws/services/kinesisanalytics/utils/ParameterToolUtils.java (11:33, 100%)
  - integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/kinesisanalytics/utils/ParameterToolUtils.java (11:33, 100%)

12 duplicated lines in:
  - integrations/flink_connector/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java (62:79, 30%)
  - integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java (73:90, 21%)

8 duplicated lines in:
  - integrations/flink_connector/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java (105:114, 20%)
  - integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java (143:152, 14%)

6 duplicated lines in:
  - integrations/flink_connector/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java (79:84, 6%)
  - integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java (82:87, 6%)

6 duplicated lines in:
  - integrations/flink_connector/src/main/java/com/amazonaws/services/timestream/TimestreamInitializer.java (18:24, 16%)
  - integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java (58:64, 6%)

6 duplicated lines in:
  - integrations/flink_connector/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java (58:64, 6%)
  - integrations/flink_connector_with_upserts/src/main/java/com/amazonaws/services/timestream/TimestreamInitializer.java (18:24, 16%)