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;
}
}