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

wenjun pushed a commit to branch cdc-multiple-table
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/cdc-multiple-table by this 
push:
     new 473971b94 Set es text type to string (#4192)
473971b94 is described below

commit 473971b94bc4c550bd6d18f61635a117f1de2bf0
Author: Wenjun Ruan <[email protected]>
AuthorDate: Thu Feb 23 14:04:46 2023 +0800

    Set es text type to string (#4192)
---
 .../seatunnel/elasticsearch/catalog/ElasticSearchDataTypeConvertor.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/catalog/ElasticSearchDataTypeConvertor.java
 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/catalog/ElasticSearchDataTypeConvertor.java
index 21b7dc0a7..aebea1c72 100644
--- 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/catalog/ElasticSearchDataTypeConvertor.java
+++ 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/catalog/ElasticSearchDataTypeConvertor.java
@@ -80,7 +80,7 @@ public class ElasticSearchDataTypeConvertor implements 
DataTypeConvertor<String>
             case DATE:
                 return LocalTimeType.LOCAL_DATE_TIME_TYPE;
             default:
-                throw new DataTypeConvertException("unsupported 
connectorDataType: " + connectorDataType);
+                return BasicType.STRING_TYPE;
         }
     }
 

Reply via email to