diff --git a/chunjun-connectors/chunjun-connector-iceberg/src/main/java/com/dtstack/chunjun/connector/iceberg/sink/ChunjunRowDataConvertMap.java b/chunjun-connectors/chunjun-connector-iceberg/src/main/java/com/dtstack/chunjun/connector/iceberg/sink/ChunjunRowDataConvertMap.java index e6e7c344c9..6dd3ef9179 100644 --- a/chunjun-connectors/chunjun-connector-iceberg/src/main/java/com/dtstack/chunjun/connector/iceberg/sink/ChunjunRowDataConvertMap.java +++ b/chunjun-connectors/chunjun-connector-iceberg/src/main/java/com/dtstack/chunjun/connector/iceberg/sink/ChunjunRowDataConvertMap.java @@ -60,6 +60,7 @@ private Object getRowDataByType(RowData data, String type, int index) { case "INT24": case "INT UNSIGNED": return data.getInt(index); + case "LONG": case "BIGINT": case "BIGINT UNSIGNED": return data.getLong(index);