From 887d0736d11500d3a556920b4586ddfcd289a030 Mon Sep 17 00:00:00 2001 From: doushuming Date: Mon, 11 Mar 2024 18:04:23 +0800 Subject: [PATCH] [bugfix][iceberg] support long type --- .../chunjun/connector/iceberg/sink/ChunjunRowDataConvertMap.java | 1 + 1 file changed, 1 insertion(+) 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);