35 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (138:193, 33%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/TimeWindow.java (152:207, 38%) 23 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (45:104, 21%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/TimeWindow.java (33:91, 25%) 14 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoProcessOperator.java (101:122, 19%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/AbstractProcessStreamOperator.java (67:88, 33%) 12 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java (877:894, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java (584:601, 3%) 11 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSink.java (77:94, 27%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sink/SinkOperator.java (125:142, 15%) 10 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (108:128, 9%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/TimeWindow.java (112:131, 10%) 9 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/Trigger.java (125:187, 34%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/triggers/Trigger.java (128:190, 40%) 8 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java (457:468, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/typeutils/TimeIntervalTypeInfo.java (75:86, 11%) 8 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java (457:468, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/dataview/ListViewTypeInfo.java (63:74, 13%) 8 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java (457:468, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapTypeInfo.java (92:103, 17%) 8 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java (457:468, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalTypeInfo.java (92:103, 12%) 8 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java (457:468, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/dataview/MapViewTypeInfo.java (83:94, 10%) 8 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java (457:468, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/InternalTypeInfo.java (169:180, 8%) 8 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/EvictingWindowOperator.java (400:411, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java (569:580, 2%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/SimpleTimerService.java (37:47, 30%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java (473:483, 2%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/LegacyKeyedCoProcessOperator.java (129:139, 7%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/AbstractProcessStreamOperator.java (67:77, 16%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithNonKeyedOperator.java (217:227, 5%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/AbstractProcessStreamOperator.java (77:87, 16%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java (111:121, 7%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/AbstractProcessStreamOperator.java (67:77, 16%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java (755:765, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java (473:483, 2%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java (599:608, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java (418:427, 2%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSink.java (59:70, 17%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sink/SinkOperator.java (107:118, 10%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/LegacyKeyedProcessOperator.java (114:124, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/AbstractProcessStreamOperator.java (67:77, 16%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java (190:200, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sink/SinkOperator.java (131:141, 10%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (349:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MatchFamilyTypeStrategy.java (54:63, 28%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java (618:626, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java (518:526, 2%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java (105:115, 10%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sink/SinkOperator.java (131:141, 10%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/KeyedCoProcessOperator.java (126:136, 7%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/AbstractProcessStreamOperator.java (67:77, 16%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (349:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FirstTypeStrategy.java (52:61, 29%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java (87:97, 10%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/AbstractProcessStreamOperator.java (67:77, 16%) 7 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (349:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MappingTypeStrategy.java (73:82, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/DataStructureConverters.java (213:219, 4%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectIdentifier.java (103:109, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RawType.java (121:127, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableFunctionDefinition.java (85:91, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RawType.java (121:127, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/DataStructureConverters.java (213:219, 4%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapSerializer.java (173:180, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/WatermarkSpec.java (74:80, 19%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableAggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DayTimeIntervalType.java (222:228, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/DecimalDataSerializer.java (118:124, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/TimeWindow.java (76:82, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionSignatureTemplate.java (106:112, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/FieldReferenceExpression.java (105:111, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWithRetractAggFunction.java (80:86, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectIdentifier.java (103:109, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeTemplate.java (231:237, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableColumn.java (86:92, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ConfigEntry.java (56:62, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimeType.java (135:141, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/RowtimeAttributeDescriptor.java (59:65, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarBinaryType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedCallExpression.java (135:141, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/YearMonthIntervalType.java (164:170, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/YearMonthIntervalType.java (164:170, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/KeyValueDataType.java (111:117, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/CollectionDataType.java (102:108, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarBinaryType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java (368:374, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/sources/tsextractors/ExistingField.java (121:127, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedReferenceExpression.java (63:69, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/LiteralArgumentTypeStrategy.java (68:74, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ArrayDataSerializer.java (232:238, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/TypeLiteralExpression.java (70:76, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/NullableTypeStrategy.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/ColumnStats.java (277:283, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DayTimeIntervalType.java (222:228, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionLookup.java (87:93, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ValuesQueryOperation.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapSerializer.java (173:180, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/FieldsDataType.java (96:102, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/BinaryType.java (147:153, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarBinaryType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/CountWindow.java (55:61, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectPath.java (68:75, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/TypeLiteralExpression.java (70:76, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitTypeStrategy.java (46:52, 31%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/LiteralArgumentTypeStrategy.java (68:74, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedReferenceExpression.java (63:69, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimestampType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ArrayDataSerializer.java (232:238, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MappingTypeStrategy.java (76:82, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FamilyArgumentTypeStrategy.java (130:136, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/KeyValueDataType.java (111:117, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UnresolvedUserDefinedType.java (100:106, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (244:250, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MatchFamilyTypeStrategy.java (57:63, 24%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (417:423, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/TimeWindow.java (76:82, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ArrayDataSerializer.java (232:238, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrInputTypeStrategy.java (149:155, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/FunctionIdentifier.java (123:129, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java (319:325, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableFunctionDefinition.java (85:91, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/FieldsDataType.java (96:102, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/RowtimeAttributeDescriptor.java (59:65, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableAggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/TimeWindow.java (76:82, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedCallExpression.java (135:141, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FamilyArgumentTypeStrategy.java (130:136, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeTemplate.java (231:237, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java (72:78, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/TableStats.java (106:112, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java (230:236, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/RowtimeAttributeDescriptor.java (59:65, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableAggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ConfigEntry.java (56:62, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SequenceInputTypeStrategy.java (101:107, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableFunctionDefinition.java (85:91, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (124:130, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarBinaryType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ArrayType.java (118:124, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapSerializer.java (173:180, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrArgumentTypeStrategy.java (108:114, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionTemplate.java (89:95, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/FieldsDataType.java (96:102, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/ColumnStats.java (277:283, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingSequenceInputTypeStrategy.java (127:133, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (244:250, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java (230:236, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UnresolvedUserDefinedType.java (100:106, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySection.java (63:69, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySection.java (63:69, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/ConstantArgumentCount.java (89:95, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionTemplate.java (89:95, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java (319:325, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionResultTemplate.java (52:58, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimeType.java (135:141, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectPath.java (68:75, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalTypeInfo.java (137:143, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/YearMonthIntervalType.java (164:170, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/AndArgumentTypeStrategy.java (97:103, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDataSerializer.java (196:202, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarCharType.java (161:167, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarCharType.java (161:167, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LookupCallExpression.java (68:74, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ArrayType.java (118:124, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ValuesQueryOperation.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarCharType.java (161:167, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/AbstractConstraint.java (55:61, 21%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/AndArgumentTypeStrategy.java (97:103, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/NullableTypeStrategy.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/CollectionDataType.java (102:108, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LegacyTypeInformationType.java (107:113, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (233:239, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectIdentifier.java (103:109, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FamilyArgumentTypeStrategy.java (130:136, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/WatermarkSpec.java (74:80, 19%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UserDefinedType.java (85:91, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/AggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionSignatureTemplate.java (106:112, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapSerializer.java (173:180, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LocalZonedTimestampType.java (171:177, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitArgumentTypeStrategy.java (76:82, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java (71:77, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDataSerializer.java (196:202, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlTableLike.java (252:258, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapTypeInfo.java (119:126, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ZonedTimestampType.java (157:163, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (113:119, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java (93:99, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LocalZonedTimestampType.java (171:177, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/NullableTypeStrategy.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DistinctType.java (139:145, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/YearMonthIntervalType.java (164:170, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlTableLike.java (252:258, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/CharType.java (153:159, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWithRetractAggFunction.java (80:86, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java (93:99, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/TableReferenceExpression.java (79:85, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LogicalType.java (180:186, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java (230:236, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ZonedTimestampType.java (157:163, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java (60:66, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectPath.java (68:75, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKindSet.java (136:142, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitTypeStrategy.java (46:52, 31%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalTypeInfo.java (137:143, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableAggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/AndArgumentTypeStrategy.java (97:103, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalSerializer.java (142:148, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (244:250, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectPath.java (68:75, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/FieldsDataType.java (96:102, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UnresolvedUserDefinedType.java (100:106, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableColumn.java (86:92, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/CountWindow.java (55:61, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionResultTemplate.java (52:58, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LegacyTypeInformationType.java (107:113, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/ChangelogMode.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DistinctType.java (139:145, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java (72:78, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/YearMonthIntervalType.java (164:170, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java (72:78, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitTypeStrategy.java (46:52, 31%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/RawValueDataSerializer.java (125:131, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/DataStructureConverters.java (213:219, 4%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java (72:78, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/FunctionIdentifier.java (123:129, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LegacyTypeInformationType.java (107:113, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LogicalType.java (180:186, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/TableReferenceExpression.java (79:85, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeTemplate.java (231:237, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MapType.java (121:127, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/RawValueDataSerializer.java (125:131, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalTypeInfo.java (137:143, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ScalarFunctionDefinition.java (75:81, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UnresolvedUserDefinedType.java (100:106, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MappingTypeStrategy.java (76:82, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (124:130, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPartitionSpec.java (52:59, 28%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithNonKeyedOperator.java (168:175, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/AbstractProcessStreamOperator.java (77:84, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java (71:77, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingSequenceInputTypeStrategy.java (127:133, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MappingTypeStrategy.java (76:82, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/UnresolvedIdentifier.java (118:124, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionSignatureTemplate.java (106:112, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/ChangelogMode.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java (1522:1528, <1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LocalZonedTimestampType.java (171:177, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (244:250, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarCharType.java (161:167, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarCharType.java (161:167, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/SymbolType.java (96:102, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java (93:99, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrArgumentTypeStrategy.java (108:114, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPartitionSpec.java (52:59, 28%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingSequenceInputTypeStrategy.java (127:133, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/ChangelogMode.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericArrayData.java (138:144, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LocalReferenceExpression.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ZonedTimestampType.java (157:163, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MultisetType.java (112:118, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/ColumnStats.java (277:283, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java (368:374, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (124:130, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionTemplate.java (89:95, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DecimalType.java (141:147, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrArgumentTypeStrategy.java (108:114, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/sources/tsextractors/ExistingField.java (121:127, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LogicalType.java (180:186, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ZonedTimestampType.java (157:163, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericArrayData.java (138:144, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ArrayType.java (118:124, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/TableReferenceExpression.java (79:85, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingStringTypeStrategy.java (82:88, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalTypeInfo.java (137:143, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MultisetType.java (112:118, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java (93:99, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/LiteralArgumentTypeStrategy.java (68:74, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/BinaryType.java (147:153, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DayTimeIntervalType.java (222:228, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/KeyValueDataType.java (111:117, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/LiteralArgumentTypeStrategy.java (68:74, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MapType.java (121:127, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LocalZonedTimestampType.java (171:177, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ConfigEntry.java (56:62, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ArrayDataSerializer.java (232:238, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/FieldsDataType.java (96:102, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MapType.java (121:127, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericArrayData.java (138:144, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectIdentifier.java (103:109, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (598:604, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/TypeLiteralExpression.java (70:76, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/WatermarkSpec.java (74:80, 19%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionLookup.java (87:93, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDataSerializer.java (196:202, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/AbstractConstraint.java (55:61, 21%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimestampType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/CollectionDataType.java (102:108, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/ChangelogMode.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableFunctionDefinition.java (85:91, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RawType.java (121:127, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/NullableTypeStrategy.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (233:239, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/AndArgumentTypeStrategy.java (97:103, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LogicalType.java (180:186, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/FieldReferenceExpression.java (105:111, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/sources/tsextractors/ExistingField.java (121:127, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/DecimalDataSerializer.java (118:124, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalSerializer.java (142:148, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectPath.java (68:75, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/TableStats.java (106:112, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SequenceInputTypeStrategy.java (101:107, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/CallExpression.java (129:135, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ConfigEntry.java (56:62, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/TableStats.java (106:112, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FirstTypeStrategy.java (55:61, 25%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/CollectAggFunction.java (78:84, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (244:250, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LocalReferenceExpression.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySection.java (63:69, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalTypeInfo.java (137:143, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (124:130, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MatchFamilyTypeStrategy.java (57:63, 24%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UserDefinedType.java (85:91, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LookupCallExpression.java (68:74, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/RawValueDataSerializer.java (125:131, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableAggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKindSet.java (136:142, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SequenceInputTypeStrategy.java (101:107, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/LiteralArgumentTypeStrategy.java (68:74, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MultisetType.java (112:118, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimestampType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/RowtimeAttributeDescriptor.java (59:65, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWithRetractAggFunction.java (80:86, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarBinaryType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MappingTypeStrategy.java (76:82, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RawType.java (121:127, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/RowtimeAttributeDescriptor.java (59:65, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FamilyArgumentTypeStrategy.java (130:136, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalSerializer.java (142:148, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/CountWindow.java (55:61, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/FieldReferenceExpression.java (105:111, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RawType.java (121:127, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java (230:236, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MultisetType.java (112:118, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LocalReferenceExpression.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/ChangelogMode.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/DecimalDataSerializer.java (118:124, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ValuesQueryOperation.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (233:239, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java (60:66, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKindSet.java (136:142, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/CallExpression.java (129:135, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/BinaryType.java (147:153, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java (230:236, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableColumn.java (86:92, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/YearMonthIntervalType.java (164:170, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UserDefinedType.java (85:91, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java (60:66, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedCallExpression.java (135:141, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedReferenceExpression.java (63:69, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/RawValueDataSerializer.java (125:131, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPartitionSpec.java (52:59, 28%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TypeInformationRawType.java (133:139, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/UnresolvedIdentifier.java (118:124, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/CollectAggFunction.java (78:84, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java (230:236, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java (60:66, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LegacyTypeInformationType.java (107:113, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/SymbolType.java (96:102, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ArrayType.java (118:124, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ConfigEntry.java (56:62, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/TimeWindow.java (76:82, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarBinaryType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/DataType.java (97:103, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/InternalTypeInfo.java (213:219, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java (71:77, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/RowtimeAttributeDescriptor.java (59:65, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/FieldsDataType.java (96:102, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/InternalTypeInfo.java (213:219, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (417:423, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LogicalType.java (180:186, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingSequenceInputTypeStrategy.java (127:133, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/TableReferenceExpression.java (79:85, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapSerializer.java (173:180, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/ColumnStats.java (277:283, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/AndArgumentTypeStrategy.java (97:103, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitArgumentTypeStrategy.java (76:82, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/CharType.java (153:159, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySection.java (63:69, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TypeInformationRawType.java (133:139, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/TimeWindow.java (76:82, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/RawValueDataSerializer.java (125:131, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedCallExpression.java (135:141, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/CallExpression.java (129:135, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/AggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/TableReferenceExpression.java (79:85, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ArrayType.java (118:124, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java (1522:1528, <1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionSignatureTemplate.java (106:112, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableFunctionDefinition.java (85:91, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java (88:94, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalSerializer.java (142:148, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/FunctionIdentifier.java (123:129, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/KeyValueDataType.java (111:117, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FamilyArgumentTypeStrategy.java (130:136, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectIdentifier.java (103:109, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/ColumnStats.java (277:283, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/AggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlTableLike.java (252:258, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FirstTypeStrategy.java (55:61, 25%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedCallExpression.java (135:141, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/YearMonthIntervalType.java (164:170, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/AbstractConstraint.java (55:61, 21%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimestampType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/CountWindow.java (55:61, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapTypeInfo.java (119:126, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionTemplate.java (89:95, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UserDefinedType.java (85:91, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/UnresolvedIdentifier.java (118:124, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalSerializer.java (142:148, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FamilyArgumentTypeStrategy.java (130:136, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPartitionSpec.java (52:59, 28%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/CharType.java (153:159, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrInputTypeStrategy.java (149:155, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/ConstantArgumentCount.java (89:95, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/TableReferenceExpression.java (79:85, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionArgumentTemplate.java (84:90, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/FunctionIdentifier.java (123:129, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrArgumentTypeStrategy.java (108:114, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/InternalTypeInfo.java (213:219, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (417:423, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (233:239, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MatchFamilyTypeStrategy.java (57:63, 24%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionResultTemplate.java (52:58, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/CollectionDataType.java (102:108, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/LiteralArgumentTypeStrategy.java (68:74, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableAggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (124:130, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DayTimeIntervalType.java (222:228, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MappingTypeStrategy.java (76:82, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDataSerializer.java (196:202, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySection.java (63:69, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (124:130, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ValuesQueryOperation.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (233:239, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MappingTypeStrategy.java (76:82, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/sources/tsextractors/ExistingField.java (121:127, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (233:239, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionArgumentTemplate.java (84:90, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ArrayDataSerializer.java (232:238, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DecimalType.java (141:147, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionLookup.java (87:93, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java (639:644, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/internal/InternalWindowProcessFunction.java (135:140, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/sources/tsextractors/ExistingField.java (121:127, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ValuesQueryOperation.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapTypeInfo.java (119:126, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWsWithRetractAggFunction.java (84:90, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionLookup.java (87:93, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingSequenceInputTypeStrategy.java (127:133, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ArrayDataSerializer.java (232:238, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySection.java (63:69, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitTypeStrategy.java (46:52, 31%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java (1522:1528, <1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UnresolvedUserDefinedType.java (100:106, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FamilyArgumentTypeStrategy.java (130:136, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/InternalTypeInfo.java (213:219, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/ColumnStats.java (277:283, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UnresolvedUserDefinedType.java (100:106, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedReferenceExpression.java (63:69, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionLookup.java (87:93, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/SymbolType.java (96:102, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDataSerializer.java (196:202, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java (88:94, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/DataType.java (97:103, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectIdentifier.java (103:109, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/CollectAggFunction.java (78:84, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeTemplate.java (231:237, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectPath.java (68:75, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/RawValueDataSerializer.java (125:131, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/sources/tsextractors/ExistingField.java (121:127, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/WatermarkSpec.java (74:80, 19%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/SymbolType.java (96:102, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java (60:66, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingStringTypeStrategy.java (82:88, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ScalarFunctionDefinition.java (75:81, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/DataType.java (97:103, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapTypeInfo.java (119:126, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/KeyValueDataType.java (111:117, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimestampType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/CollectAggFunction.java (78:84, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/LiteralArgumentTypeStrategy.java (68:74, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericArrayData.java (138:144, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/LiteralArgumentTypeStrategy.java (68:74, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/KeyValueDataType.java (111:117, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DayTimeIntervalType.java (222:228, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/SymbolType.java (96:102, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DecimalType.java (141:147, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/CountWindow.java (55:61, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWsWithRetractAggFunction.java (84:90, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionTemplate.java (89:95, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/AbstractConstraint.java (55:61, 21%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (417:423, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SequenceInputTypeStrategy.java (101:107, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPartitionSpec.java (52:59, 28%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/FieldReferenceExpression.java (105:111, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapTypeInfo.java (119:126, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java (71:77, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FirstTypeStrategy.java (55:61, 25%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarCharType.java (161:167, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UnresolvedUserDefinedType.java (100:106, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingSequenceInputTypeStrategy.java (127:133, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionArgumentTemplate.java (84:90, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlTableLike.java (252:258, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKindSet.java (136:142, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingSequenceInputTypeStrategy.java (127:133, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/UnresolvedIdentifier.java (118:124, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/sources/tsextractors/ExistingField.java (121:127, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (113:119, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrInputTypeStrategy.java (149:155, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/TypeLiteralExpression.java (70:76, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/ConstantArgumentCount.java (89:95, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/CharType.java (153:159, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DecimalType.java (141:147, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java (842:850, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java (609:617, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/YearMonthIntervalType.java (164:170, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrArgumentTypeStrategy.java (108:114, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (417:423, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/NullableTypeStrategy.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (113:119, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeTemplate.java (231:237, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/AbstractConstraint.java (55:61, 21%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ArrayType.java (118:124, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MapType.java (121:127, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWsWithRetractAggFunction.java (84:90, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeTemplate.java (231:237, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/TypeLiteralExpression.java (70:76, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimeType.java (135:141, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPartitionSpec.java (52:59, 28%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MapType.java (121:127, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericArrayData.java (138:144, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarBinaryType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/DataType.java (97:103, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalSerializer.java (142:148, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapSerializer.java (173:180, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericArrayData.java (138:144, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedCallExpression.java (135:141, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericArrayData.java (138:144, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java (72:78, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MapType.java (121:127, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/CollectionDataType.java (102:108, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MapType.java (121:127, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimestampType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java (368:374, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/TableStats.java (106:112, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/WatermarkSpec.java (74:80, 19%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlTableLike.java (252:258, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java (72:78, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DistinctType.java (139:145, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrInputTypeStrategy.java (149:155, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionSignatureTemplate.java (106:112, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LookupCallExpression.java (68:74, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/CallExpression.java (129:135, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/SymbolType.java (96:102, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java (319:325, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ValuesQueryOperation.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/CollectionDataType.java (102:108, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (598:604, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrArgumentTypeStrategy.java (108:114, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ArrayType.java (118:124, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DayTimeIntervalType.java (222:228, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java (72:78, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TypeInformationRawType.java (133:139, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/FieldsDataType.java (96:102, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/TimeWindow.java (76:82, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ArrayType.java (118:124, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (417:423, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimeType.java (135:141, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/ConstantArgumentCount.java (89:95, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPartitionSpec.java (52:59, 28%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlTableLike.java (252:258, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UserDefinedType.java (85:91, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (598:604, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWithRetractAggFunction.java (80:86, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LocalReferenceExpression.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/InternalTypeInfo.java (213:219, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrInputTypeStrategy.java (149:155, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/AggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java (319:325, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LocalReferenceExpression.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapTypeInfo.java (119:126, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimeType.java (135:141, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SequenceInputTypeStrategy.java (101:107, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/FieldReferenceExpression.java (105:111, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java (71:77, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/BinaryType.java (147:153, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MultisetType.java (112:118, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/FieldReferenceExpression.java (105:111, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/ConstantArgumentCount.java (89:95, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableAggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MatchFamilyTypeStrategy.java (57:63, 24%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/ChangelogMode.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectIdentifier.java (103:109, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/TableStats.java (106:112, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (244:250, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ZonedTimestampType.java (157:163, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UserDefinedType.java (85:91, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java (93:99, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/FieldReferenceExpression.java (105:111, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (417:423, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDataSerializer.java (196:202, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TypeInformationRawType.java (133:139, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java (71:77, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/WatermarkSpec.java (74:80, 19%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UserDefinedType.java (85:91, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeTemplate.java (231:237, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/CharType.java (153:159, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DistinctType.java (139:145, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DayTimeIntervalType.java (222:228, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/DecimalDataSerializer.java (118:124, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/SocketStreamIterator.java (153:161, 8%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/SingleElementIterator.java (53:61, 26%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalSerializer.java (142:148, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java (88:94, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionSignatureTemplate.java (106:112, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionArgumentTemplate.java (84:90, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/UnresolvedIdentifier.java (118:124, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/CountWindow.java (55:61, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RawType.java (121:127, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitArgumentTypeStrategy.java (76:82, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarBinaryType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeTemplate.java (231:237, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/UnresolvedIdentifier.java (118:124, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingStringTypeStrategy.java (82:88, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableColumn.java (86:92, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingStringTypeStrategy.java (82:88, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/FieldsDataType.java (96:102, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/TimeWindow.java (76:82, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/DecimalDataSerializer.java (118:124, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionLookup.java (87:93, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/WatermarkSpec.java (74:80, 19%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ScalarFunctionDefinition.java (75:81, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MatchFamilyTypeStrategy.java (57:63, 24%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/CharType.java (153:159, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/AbstractConstraint.java (55:61, 21%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LogicalType.java (180:186, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (113:119, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionResultTemplate.java (52:58, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (124:130, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FirstTypeStrategy.java (55:61, 25%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ConfigEntry.java (56:62, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TypeInformationRawType.java (133:139, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionTemplate.java (89:95, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionLookup.java (87:93, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimestampType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/NullableTypeStrategy.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/ConstantArgumentCount.java (89:95, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SequenceInputTypeStrategy.java (101:107, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableColumn.java (86:92, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionTemplate.java (89:95, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableFunctionDefinition.java (85:91, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (113:119, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/DataStructureConverters.java (213:219, 4%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LocalZonedTimestampType.java (171:177, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RawType.java (121:127, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/TypeLiteralExpression.java (70:76, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java (368:374, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/InternalTypeInfo.java (213:219, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DecimalType.java (141:147, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ScalarFunctionDefinition.java (75:81, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java (368:374, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MatchFamilyTypeStrategy.java (57:63, 24%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/CollectionDataType.java (102:108, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RawType.java (121:127, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DecimalType.java (141:147, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SequenceInputTypeStrategy.java (101:107, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LocalZonedTimestampType.java (171:177, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MappingTypeStrategy.java (76:82, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/TableReferenceExpression.java (79:85, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (113:119, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ConfigEntry.java (56:62, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrInputTypeStrategy.java (149:155, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/FieldReferenceExpression.java (105:111, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ConfigEntry.java (56:62, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java (319:325, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionTemplate.java (89:95, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitTypeStrategy.java (46:52, 31%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrInputTypeStrategy.java (149:155, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LegacyTypeInformationType.java (107:113, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/AggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWsWithRetractAggFunction.java (84:90, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlTableLike.java (252:258, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionSignatureTemplate.java (106:112, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/FunctionIdentifier.java (123:129, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalTypeInfo.java (137:143, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java (1522:1528, <1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectIdentifier.java (103:109, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitTypeStrategy.java (46:52, 31%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java (1522:1528, <1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableColumn.java (86:92, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java (71:77, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/UnresolvedIdentifier.java (118:124, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java (60:66, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapTypeInfo.java (119:126, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingStringTypeStrategy.java (82:88, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWsWithRetractAggFunction.java (84:90, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DayTimeIntervalType.java (222:228, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/CharType.java (153:159, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDataSerializer.java (196:202, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/CollectAggFunction.java (78:84, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LocalReferenceExpression.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlTableLike.java (252:258, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedCallExpression.java (135:141, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java (1522:1528, <1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/InternalTypeInfo.java (213:219, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java (368:374, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java (319:325, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/sources/tsextractors/ExistingField.java (121:127, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (417:423, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ArrayType.java (118:124, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DistinctType.java (139:145, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/AndArgumentTypeStrategy.java (97:103, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/BinaryType.java (147:153, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FirstTypeStrategy.java (55:61, 25%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedReferenceExpression.java (63:69, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (124:130, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/CharType.java (153:159, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableFunctionDefinition.java (85:91, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LookupCallExpression.java (68:74, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableColumn.java (86:92, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/SymbolType.java (96:102, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrArgumentTypeStrategy.java (108:114, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java (88:94, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java (88:94, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LogicalType.java (180:186, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionResultTemplate.java (52:58, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UnresolvedUserDefinedType.java (100:106, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java (88:94, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/TableStats.java (106:112, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/FunctionIdentifier.java (123:129, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/CollectAggFunction.java (78:84, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWsWithRetractAggFunction.java (84:90, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/ConstantArgumentCount.java (89:95, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/RawValueDataSerializer.java (125:131, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LookupCallExpression.java (68:74, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectPath.java (68:75, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableFunctionDefinition.java (85:91, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/NullableTypeStrategy.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LegacyTypeInformationType.java (107:113, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/WatermarkSpec.java (74:80, 19%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedCallExpression.java (135:141, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (598:604, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/AbstractConstraint.java (55:61, 21%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingSequenceInputTypeStrategy.java (127:133, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java (88:94, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/AggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKindSet.java (136:142, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/CollectAggFunction.java (78:84, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeTemplate.java (231:237, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java (88:94, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionResultTemplate.java (52:58, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ScalarFunctionDefinition.java (75:81, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ConfigEntry.java (56:62, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarCharType.java (161:167, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDataSerializer.java (196:202, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SequenceInputTypeStrategy.java (101:107, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/DataType.java (97:103, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/FieldReferenceExpression.java (105:111, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/FunctionIdentifier.java (123:129, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/AndArgumentTypeStrategy.java (97:103, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java (60:66, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LogicalType.java (180:186, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/DataStructureConverters.java (213:219, 4%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/CallExpression.java (129:135, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (598:604, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySection.java (63:69, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlTableLike.java (252:258, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKindSet.java (136:142, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionResultTemplate.java (52:58, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LegacyTypeInformationType.java (107:113, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWithRetractAggFunction.java (80:86, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitArgumentTypeStrategy.java (76:82, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/AbstractConstraint.java (55:61, 21%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java (72:78, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/ChangelogMode.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LocalZonedTimestampType.java (171:177, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionSignatureTemplate.java (106:112, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/AggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitArgumentTypeStrategy.java (76:82, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java (319:325, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectPath.java (68:75, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ZonedTimestampType.java (157:163, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimestampType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/AndArgumentTypeStrategy.java (97:103, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LegacyTypeInformationType.java (107:113, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java (1522:1528, <1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/PrintSinkFunction.java (72:79, 28%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/PrintTableSinkFactory.java (152:159, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWithRetractAggFunction.java (80:86, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectPath.java (68:75, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalSerializer.java (142:148, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionArgumentTemplate.java (84:90, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalTypeInfo.java (137:143, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (244:250, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java (93:99, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/DataType.java (97:103, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPartitionSpec.java (52:59, 28%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LogicalType.java (180:186, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/AggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (244:250, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ObjectIdentifier.java (103:109, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingStringTypeStrategy.java (82:88, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/RawValueDataSerializer.java (125:131, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/BinaryType.java (147:153, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java (230:236, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/AndArgumentTypeStrategy.java (97:103, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWithRetractAggFunction.java (80:86, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableAggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (244:250, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java (368:374, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimeType.java (135:141, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimeType.java (135:141, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/BinaryType.java (147:153, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/TypeLiteralExpression.java (70:76, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/CallExpression.java (129:135, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/ConstantArgumentCount.java (89:95, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (233:239, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitArgumentTypeStrategy.java (76:82, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKindSet.java (136:142, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericArrayData.java (138:144, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/TableStats.java (106:112, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MapType.java (121:127, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TypeInformationRawType.java (133:139, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/CollectAggFunction.java (78:84, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ZonedTimestampType.java (157:163, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWithRetractAggFunction.java (80:86, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/BinaryType.java (147:153, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableFunctionDefinition.java (85:91, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LocalReferenceExpression.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericArrayData.java (138:144, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MultisetType.java (112:118, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java (93:99, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (233:239, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingStringTypeStrategy.java (82:88, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/CallExpression.java (129:135, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDataSerializer.java (196:202, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/DataStructureConverters.java (213:219, 4%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MapType.java (121:127, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LookupCallExpression.java (68:74, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LocalReferenceExpression.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/SymbolType.java (96:102, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedReferenceExpression.java (63:69, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/CallExpression.java (129:135, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/DataType.java (97:103, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableColumn.java (86:92, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/FieldsDataType.java (96:102, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SequenceInputTypeStrategy.java (101:107, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingStringTypeStrategy.java (82:88, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedReferenceExpression.java (63:69, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySection.java (63:69, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DistinctType.java (139:145, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/CountWindow.java (55:61, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java (319:325, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DistinctType.java (139:145, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UserDefinedType.java (85:91, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/TableReferenceExpression.java (79:85, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FirstTypeStrategy.java (55:61, 25%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (598:604, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionSignatureTemplate.java (106:112, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java (60:66, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedReferenceExpression.java (63:69, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/BinaryType.java (147:153, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitTypeStrategy.java (46:52, 31%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ConstraintArgumentTypeStrategy.java (72:78, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java (230:236, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/DataStructureConverters.java (213:219, 4%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimeType.java (135:141, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java (319:325, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPartitionSpec.java (52:59, 28%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/CollectionDataType.java (102:108, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FirstTypeStrategy.java (55:61, 25%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalTypeInfo.java (137:143, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrArgumentTypeStrategy.java (108:114, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java (368:374, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java (368:374, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/UnresolvedIdentifier.java (118:124, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (598:604, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/TableStats.java (106:112, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/SymbolType.java (96:102, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ScalarFunctionDefinition.java (75:81, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LocalZonedTimestampType.java (171:177, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/DataType.java (97:103, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ValuesQueryOperation.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DecimalType.java (141:147, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MappingTypeStrategy.java (76:82, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionArgumentTemplate.java (84:90, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/DecimalDataSerializer.java (118:124, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/InternalTypeInfo.java (213:219, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/TableStats.java (106:112, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (233:239, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MultisetType.java (112:118, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapSerializer.java (173:180, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java (60:66, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TypeInformationRawType.java (133:139, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySection.java (63:69, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/TypeLiteralExpression.java (70:76, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitArgumentTypeStrategy.java (76:82, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitArgumentTypeStrategy.java (76:82, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/CallExpression.java (129:135, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/DecimalDataSerializer.java (118:124, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalTypeInfo.java (137:143, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LookupCallExpression.java (68:74, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitArgumentTypeStrategy.java (76:82, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/AggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitTypeStrategy.java (46:52, 31%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableAggregateFunctionDefinition.java (92:98, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RawType.java (121:127, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ArrayDataSerializer.java (232:238, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ScalarFunctionDefinition.java (75:81, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKindSet.java (136:142, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (417:423, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java (1522:1528, <1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (598:604, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/ConstantArgumentCount.java (89:95, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionLookup.java (87:93, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/CollectAggFunction.java (78:84, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/RawValueDataSerializer.java (125:131, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/DataType.java (97:103, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWsWithRetractAggFunction.java (84:90, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/CharType.java (153:159, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DistinctType.java (139:145, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/ColumnStats.java (277:283, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/AbstractConstraint.java (55:61, 21%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/NullableTypeStrategy.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapSerializer.java (173:180, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LookupCallExpression.java (68:74, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKindSet.java (136:142, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableColumn.java (86:92, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/DataStructureConverters.java (213:219, 4%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/YearMonthIntervalType.java (164:170, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/RowtimeAttributeDescriptor.java (59:65, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UnresolvedUserDefinedType.java (100:106, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/TableReferenceExpression.java (79:85, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarCharType.java (161:167, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/CountWindow.java (55:61, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java (88:94, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java (124:130, 2%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DayTimeIntervalType.java (222:228, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/KeyValueDataType.java (111:117, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/RowtimeAttributeDescriptor.java (59:65, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedCallExpression.java (135:141, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ScalarFunctionDefinition.java (75:81, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrArgumentTypeStrategy.java (108:114, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/UnresolvedReferenceExpression.java (63:69, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/ChangelogMode.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/ChangelogMode.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrInputTypeStrategy.java (149:155, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/KeyValueDataType.java (111:117, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionResultTemplate.java (52:58, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MatchFamilyTypeStrategy.java (57:63, 24%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionResultTemplate.java (52:58, 27%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarBinaryType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java (598:604, 1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LegacyTypeInformationType.java (107:113, 12%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FamilyArgumentTypeStrategy.java (130:136, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimeType.java (135:141, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LocalZonedTimestampType.java (171:177, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/UnresolvedIdentifier.java (118:124, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ValuesQueryOperation.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/LiteralArgumentTypeStrategy.java (68:74, 18%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/TimeWindow.java (76:82, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/RowtimeAttributeDescriptor.java (59:65, 20%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/OrInputTypeStrategy.java (149:155, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LookupCallExpression.java (68:74, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TypeInformationRawType.java (133:139, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWsWithRetractAggFunction.java (84:90, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionArgumentTemplate.java (84:90, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/NullableTypeStrategy.java (77:83, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingSequenceInputTypeStrategy.java (127:133, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java (230:236, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MultisetType.java (112:118, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/CollectionDataType.java (102:108, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DecimalType.java (141:147, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/DecimalDataSerializer.java (118:124, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/ColumnStats.java (277:283, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapTypeInfo.java (119:126, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/DataStructureConverters.java (213:219, 4%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java (93:99, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TypeInformationRawType.java (133:139, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/FunctionIdentifier.java (123:129, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ZonedTimestampType.java (157:163, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWsWithRetractAggFunction.java (84:90, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java (71:77, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/ZonedTimestampType.java (157:163, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java (93:99, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DecimalType.java (141:147, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/DecimalDataSerializer.java (118:124, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/CountWindow.java (55:61, 9%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/FunctionIdentifier.java (123:129, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalSerializer.java (142:148, 5%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/TypeLiteralExpression.java (70:76, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionArgumentTemplate.java (84:90, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ExplicitTypeStrategy.java (46:52, 31%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/KeyValueDataType.java (111:117, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (113:119, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ValuesQueryOperation.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/plan/stats/ColumnStats.java (277:283, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FamilyArgumentTypeStrategy.java (130:136, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java (71:77, 17%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java (1522:1528, <1%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/MultisetType.java (112:118, 11%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapSerializer.java (173:180, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionTemplate.java (89:95, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionLookup.java (87:93, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/UserDefinedType.java (85:91, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (113:119, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ArrayDataSerializer.java (232:238, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/VaryingStringTypeStrategy.java (82:88, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ScalarFunctionDefinition.java (75:81, 16%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) - flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWithRetractAggFunction.java (80:86, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java (113:119, 3%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/InternalTypeInfo.java (213:219, 6%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DistinctType.java (139:145, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/TimestampType.java (155:161, 8%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/AbstractMapTypeInfo.java (119:126, 13%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/VarCharType.java (161:167, 7%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionArgumentTemplate.java (84:90, 14%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MatchFamilyTypeStrategy.java (57:63, 24%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FirstTypeStrategy.java (55:61, 25%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/sources/tsextractors/ExistingField.java (121:127, 10%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) - flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/LocalReferenceExpression.java (76:82, 15%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) - flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/WatermarkSpec.java (74:80, 19%) 6 duplicated lines in: - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) - flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ArrayDataSerializer.java (232:238, 3%)