8 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/GenericRecordAvroTypeInfo.java (48:59, 17%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java (457:468, 2%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/HadoopPathBasedBulkFormatBuilder.java (120:125, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java (366:371, 3%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/HadoopPathBasedBulkFormatBuilder.java (95:102, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java (333:340, 3%) 6 duplicated lines in: - flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPartFileWriter.java (58:65, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BulkPartWriter.java (46:53, 27%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/HadoopPathBasedBulkFormatBuilder.java (120:125, 8%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java (255:260, 3%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%)