8 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/datastream/typeinfo/python/PickledByteArrayTypeInfo.java (36:47, 22%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java (457:468, 2%)

6 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/AbstractArrowSourceFunction.java (136:142, 6%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java (144:151, 3%)

6 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%)

6 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/AbstractArrowSourceFunction.java (136:142, 6%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java (69:76, 11%)

6 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%)

6 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%)

6 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%)

6 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%)

6 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%)

6 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%)

6 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%)

6 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java (106:112, 6%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%)

6 duplicated lines in:
  - flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/AbstractArrowSourceFunction.java (136:142, 6%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java (101:107, 6%)