12 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (113:149, 30%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/time/Time.java (89:125, 48%) 11 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (40:77, 27%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/time/Time.java (35:72, 44%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/ListTypeInfo.java (67:78, 15%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java (457:468, 2%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/MapTypeInfo.java (79:90, 13%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java (457:468, 2%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoField.java (58:67, 23%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java (274:283, 4%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/SqlTimeTypeInfo.java (70:81, 10%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java (457:468, 2%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/LocalTimeTypeInfo.java (72:83, 10%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java (457:468, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/eventtime/Watermark.java (58:76, 24%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/watermark/Watermark.java (45:63, 33%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%)