[sqlserver] Add support bigint type as table split column (apache#2416)

zhongqishang · Aug 22, 2023 · 2f79b24 · 2f79b24
1 parent 6fa02ef
commit 2f79b24
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...src/main/java/com/ververica/cdc/connectors/sqlserver/source/utils/SqlServerTypeUtils.java b/...src/main/java/com/ververica/cdc/connectors/sqlserver/source/utils/SqlServerTypeUtils.java
@@ -55,6 +55,8 @@ private static DataType convertFromColumn(Column column) {
             case Types.SMALLINT:
             case Types.TINYINT:
                 return DataTypes.INT();
+            case Types.BIGINT:
+                return DataTypes.BIGINT();
             case Types.FLOAT:
             case Types.REAL:
             case Types.DOUBLE: