Skip to content

Commit db16f3d

Browse files
GOODBOY008zhongqishang
authored andcommitted
[sqlserver] Add support bigint type as table split column (apache#2416)
(cherry picked from commit 2f79b24)
1 parent 09ef8b5 commit db16f3d

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

flink-connector-sqlserver-cdc/src/main/java/com/ververica/cdc/connectors/sqlserver/source/utils/SqlServerTypeUtils.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,8 @@ private static DataType convertFromColumn(Column column) {
5555
case Types.SMALLINT:
5656
case Types.TINYINT:
5757
return DataTypes.INT();
58+
case Types.BIGINT:
59+
return DataTypes.BIGINT();
5860
case Types.FLOAT:
5961
case Types.REAL:
6062
case Types.DOUBLE:

0 commit comments

Comments
 (0)