Skip to content

Commit 0491a33

Browse files
authored
[hotfix] fix user-defined schema for bytes type translattion (apache#2530)
* bytes should byte[] * update some unit test * update some unit test
1 parent 28fb446 commit 0491a33

File tree

2 files changed

+6
-1
lines changed
  • seatunnel-connectors-v2/connector-common/src

2 files changed

+6
-1
lines changed

seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/schema/SeatunnelSchema.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import org.apache.seatunnel.api.table.type.DecimalType;
2323
import org.apache.seatunnel.api.table.type.LocalTimeType;
2424
import org.apache.seatunnel.api.table.type.MapType;
25+
import org.apache.seatunnel.api.table.type.PrimitiveByteArrayType;
2526
import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
2627
import org.apache.seatunnel.api.table.type.SeaTunnelRowType;
2728
import org.apache.seatunnel.api.table.type.SqlType;
@@ -155,8 +156,9 @@ private static SeaTunnelDataType<?> parseTypeByString(String type) {
155156
case BOOLEAN:
156157
return BasicType.BOOLEAN_TYPE;
157158
case TINYINT:
158-
case BYTES:
159159
return BasicType.BYTE_TYPE;
160+
case BYTES:
161+
return PrimitiveByteArrayType.INSTANCE;
160162
case SMALLINT:
161163
return BasicType.SHORT_TYPE;
162164
case INT:

seatunnel-connectors-v2/connector-common/src/test/java/org/apache/seatunnel/connector/common/schema/SchemaParseTest.java

+3
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import org.apache.seatunnel.api.table.type.BasicType;
2222
import org.apache.seatunnel.api.table.type.DecimalType;
2323
import org.apache.seatunnel.api.table.type.MapType;
24+
import org.apache.seatunnel.api.table.type.PrimitiveByteArrayType;
2425
import org.apache.seatunnel.api.table.type.SeaTunnelRowType;
2526
import org.apache.seatunnel.connectors.seatunnel.common.schema.SeatunnelSchema;
2627

@@ -53,6 +54,8 @@ public void testSimpleSchemaParse() throws FileNotFoundException, URISyntaxExcep
5354
Assertions.assertEquals(seaTunnelRowType.getFieldType(1), ArrayType.BYTE_ARRAY_TYPE);
5455
Assertions.assertEquals(seaTunnelRowType.getFieldType(2), BasicType.STRING_TYPE);
5556
Assertions.assertEquals(seaTunnelRowType.getFieldType(10), new DecimalType(30, 8));
57+
Assertions.assertEquals(seaTunnelRowType.getFieldType(11), BasicType.VOID_TYPE);
58+
Assertions.assertEquals(seaTunnelRowType.getFieldType(12), PrimitiveByteArrayType.INSTANCE);
5659
}
5760

5861
@Test

0 commit comments

Comments
 (0)