(doris-flink-connector) branch master updated: [fix] Support converting type BINARY of Flink to Doris type (#397) (#398)

[diwu]

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

diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new a1cadf40 [fix] Support converting type BINARY of Flink to Doris type 
(#397) (#398)
a1cadf40 is described below

commit a1cadf407b45e50f9100a0df7b739f4d758f050d
Author: North Lin <37775475+qg-...@users.noreply.github.com>
AuthorDate: Fri Jun 7 11:14:21 2024 +0800

    [fix] Support converting type BINARY of Flink to Doris type (#397) (#398)
---
 .../main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java   | 6 ++++++
 .../java/org/apache/doris/flink/catalog/DorisTypeMapperTest.java    | 6 ++++++
 2 files changed, 12 insertions(+)

diff --git 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java
 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java
index 55ab7b73..ba612256 100644
--- 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java
+++ 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java
@@ -21,6 +21,7 @@ import org.apache.flink.table.api.DataTypes;
 import org.apache.flink.table.types.DataType;
 import org.apache.flink.table.types.logical.ArrayType;
 import org.apache.flink.table.types.logical.BigIntType;
+import org.apache.flink.table.types.logical.BinaryType;
 import org.apache.flink.table.types.logical.BooleanType;
 import org.apache.flink.table.types.logical.CharType;
 import org.apache.flink.table.types.logical.DateType;
@@ -240,6 +241,11 @@ public class DorisTypeMapper {
             return STRING;
         }
 
+        @Override
+        public String visit(BinaryType binaryType) {
+            return STRING;
+        }
+
         @Override
         protected String defaultMethod(LogicalType logicalType) {
             throw new UnsupportedOperationException(
diff --git 
a/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisTypeMapperTest.java
 
b/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisTypeMapperTest.java
index 5d102f9e..2be07913 100644
--- 
a/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisTypeMapperTest.java
+++ 
b/flink-doris-connector/src/test/java/org/apache/doris/flink/catalog/DorisTypeMapperTest.java
@@ -176,4 +176,10 @@ public class DorisTypeMapperTest {
                         DataTypes.ROW(DataTypes.FIELD("field", 
DataTypes.INT())));
         assertEquals("STRING", dorisType);
     }
+
+    @Test
+    public void testBinaryType() {
+        String dorisType = DorisTypeMapper.toDorisType(DataTypes.BINARY(1));
+        assertEquals("STRING", dorisType);
+    }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org