10 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (52:66, 25%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (123:137, 9%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) - 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) - 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) - 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java (190:196, 3%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/UdfDef.java (49:55, 25%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java (90:96, 9%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/ModelDef.java (60:66, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/RouteDef.java (84:90, 12%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 10%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java (69:75, 13%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java (131:137, 5%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) - 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java (76:82, 15%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/NullableSerializerWrapper.java (103:109, 6%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java (139:145, 5%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java (213:219, 3%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SinkDef.java (101:107, 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-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/DecimalDataSerializer.java (113:119, 5%) 6 duplicated lines in: - flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java (134:140, 6%) - flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java (184:190, 2%)