Skip to content

Commit 21afe82

Browse files
committed
[bugfix] Fix the bug that flink decimal cannot be converted to the starRocks bigint unsigned data type.
Signed-off-by: danzhewuju <[email protected]>
1 parent 98226dd commit 21afe82

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/main/java/com/starrocks/connector/flink/manager/StarRocksSinkTable.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -228,6 +228,7 @@ public StarRocksSinkTable build() {
228228
typesMap.put("smallint", Arrays.asList(LogicalTypeRoot.SMALLINT, LogicalTypeRoot.INTEGER, LogicalTypeRoot.BINARY));
229229
typesMap.put("varchar", Arrays.asList(LogicalTypeRoot.VARCHAR, LogicalTypeRoot.ARRAY, LogicalTypeRoot.MAP, LogicalTypeRoot.ROW));
230230
typesMap.put("string", Arrays.asList(LogicalTypeRoot.CHAR, LogicalTypeRoot.VARCHAR, LogicalTypeRoot.ARRAY, LogicalTypeRoot.MAP, LogicalTypeRoot.ROW));
231+
typesMap.put("bigint unsigned", Arrays.asList(LogicalTypeRoot.DECIMAL));
231232
}
232233

233234
}

0 commit comments

Comments
 (0)