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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
