Skip to content

Commit 47a72c7

Browse files
dou-doudoushuming
andauthored
[bugfix][iceberg] support long type (#1887)
Co-authored-by: doushuming <mm1326703389@163.com>
1 parent 6ef21b6 commit 47a72c7

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

chunjun-connectors/chunjun-connector-iceberg/src/main/java/com/dtstack/chunjun/connector/iceberg/sink/ChunjunRowDataConvertMap.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@ private Object getRowDataByType(RowData data, String type, int index) {
6060
case "INT24":
6161
case "INT UNSIGNED":
6262
return data.getInt(index);
63+
case "LONG":
6364
case "BIGINT":
6465
case "BIGINT UNSIGNED":
6566
return data.getLong(index);

0 commit comments

Comments
 (0)