7 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaMergingUtils.java (875:881, 1%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/SystemFunctionUtils.java (1034:1040, 1%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java (102:108, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java (113:119, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java (126:131, 1%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java (230:235, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java (119:125, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java (106:112, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java (113:119, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java (109:115, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java (64:70, 16%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java (87:93, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java (80:86, 14%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java (123:129, 4%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java (120:126, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java (89:95, 13%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java (154:160, 3%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java (94:100, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java (136:142, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java (94:100, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java (90:96, 11%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%)