Skip to content

Commit 2f79b24

Browse files
authored
[sqlserver] Add support bigint type as table split column (#2416)
1 parent 6fa02ef commit 2f79b24

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)