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 b2df07c [improve](cdc-tool) support sqlserver uniqueidentifier type
(#276)
b2df07c is described below
commit b2df07cd60735ac0c878e9ad4a54a682913f3742
Author: zy-kkk <[email protected]>
AuthorDate: Wed Dec 20 10:53:27 2023 +0800
[improve](cdc-tool) support sqlserver uniqueidentifier type (#276)
---
.../java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java
index f09eac1..dace43f 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java
@@ -41,6 +41,7 @@ public class SqlServerType {
private static final String NVARCHAR = "nvarchar";
private static final String TEXT = "text";
private static final String NTEXT = "ntext";
+ private static final String UNIQUEIDENTIFIER = "uniqueidentifier";
private static final String TIME = "time";
private static final String TIMESTAMP = "timestamp";
private static final String DATETIMEOFFSET = "datetimeoffset";
@@ -100,6 +101,7 @@ public class SqlServerType {
case TIME:
case DATETIMEOFFSET:
case TIMESTAMP:
+ case UNIQUEIDENTIFIER:
return DorisType.STRING;
default:
throw new UnsupportedOperationException(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
