[incubator-seatunnel] branch dev updated: [hotfix] fix user-defined schema for bytes type translattion (#2530)

[zongwen]

This is an automated email from the ASF dual-hosted git repository.

zongwen pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 0491a33ed [hotfix] fix user-defined schema for bytes type translattion 
(#2530)
0491a33ed is described below

commit 0491a33edca0a804a9c244cf9c60bb9df5580980
Author: Laglangyue <35491928+laglang...@users.noreply.github.com>
AuthorDate: Fri Aug 26 03:21:37 2022 +0800

    [hotfix] fix user-defined schema for bytes type translattion (#2530)
    
    * bytes should byte[]
    
    * update some unit test
    
    * update some unit test
---
 .../seatunnel/connectors/seatunnel/common/schema/SeatunnelSchema.java | 4 +++-
 .../org/apache/seatunnel/connector/common/schema/SchemaParseTest.java | 3 +++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/schema/SeatunnelSchema.java
 
b/seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/schema/SeatunnelSchema.java
index 835d1d0ca..fbf481375 100644
--- 
a/seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/schema/SeatunnelSchema.java
+++ 
b/seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/schema/SeatunnelSchema.java
@@ -22,6 +22,7 @@ import org.apache.seatunnel.api.table.type.BasicType;
 import org.apache.seatunnel.api.table.type.DecimalType;
 import org.apache.seatunnel.api.table.type.LocalTimeType;
 import org.apache.seatunnel.api.table.type.MapType;
+import org.apache.seatunnel.api.table.type.PrimitiveByteArrayType;
 import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
 import org.apache.seatunnel.api.table.type.SeaTunnelRowType;
 import org.apache.seatunnel.api.table.type.SqlType;
@@ -155,8 +156,9 @@ public class SeatunnelSchema implements Serializable {
             case BOOLEAN:
                 return BasicType.BOOLEAN_TYPE;
             case TINYINT:
-            case BYTES:
                 return BasicType.BYTE_TYPE;
+            case BYTES:
+                return PrimitiveByteArrayType.INSTANCE;
             case SMALLINT:
                 return BasicType.SHORT_TYPE;
             case INT:
diff --git 
a/seatunnel-connectors-v2/connector-common/src/test/java/org/apache/seatunnel/connector/common/schema/SchemaParseTest.java
 
b/seatunnel-connectors-v2/connector-common/src/test/java/org/apache/seatunnel/connector/common/schema/SchemaParseTest.java
index e05c69f73..cbd398547 100644
--- 
a/seatunnel-connectors-v2/connector-common/src/test/java/org/apache/seatunnel/connector/common/schema/SchemaParseTest.java
+++ 
b/seatunnel-connectors-v2/connector-common/src/test/java/org/apache/seatunnel/connector/common/schema/SchemaParseTest.java
@@ -21,6 +21,7 @@ import org.apache.seatunnel.api.table.type.ArrayType;
 import org.apache.seatunnel.api.table.type.BasicType;
 import org.apache.seatunnel.api.table.type.DecimalType;
 import org.apache.seatunnel.api.table.type.MapType;
+import org.apache.seatunnel.api.table.type.PrimitiveByteArrayType;
 import org.apache.seatunnel.api.table.type.SeaTunnelRowType;
 import org.apache.seatunnel.connectors.seatunnel.common.schema.SeatunnelSchema;
 
@@ -53,6 +54,8 @@ public class SchemaParseTest {
         Assertions.assertEquals(seaTunnelRowType.getFieldType(1), 
ArrayType.BYTE_ARRAY_TYPE);
         Assertions.assertEquals(seaTunnelRowType.getFieldType(2), 
BasicType.STRING_TYPE);
         Assertions.assertEquals(seaTunnelRowType.getFieldType(10), new 
DecimalType(30, 8));
+        Assertions.assertEquals(seaTunnelRowType.getFieldType(11), 
BasicType.VOID_TYPE);
+        Assertions.assertEquals(seaTunnelRowType.getFieldType(12), 
PrimitiveByteArrayType.INSTANCE);
     }
 
     @Test