Skip to content

Commit eb303a4

Browse files
committed
[hotfix-36557][kudu] 修复kudu维表,定义为nullable的字段值为null时,获取数据失败
1 parent 88984ff commit eb303a4

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

kudu/kudu-side/kudu-all-side/src/main/java/com/dtstack/flink/sql/side/kudu/KuduAllReqRow.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -150,7 +150,7 @@ private void loadData(Map<String, List<Map<String, Object>>> tmpCache) {
150150
String sideFieldName = sideFieldName1.trim();
151151
ColumnSchema columnSchema = table.getSchema().getColumn(sideFieldName);
152152
if (null != columnSchema) {
153-
KuduUtil.setMapValue(columnSchema.getType(), oneRow, sideFieldName, result);
153+
oneRow.put(sideFieldName, result.getObject(sideFieldName));
154154
}
155155
}
156156
String cacheKey = buildKey(oneRow, sideInfo.getEqualFieldList());

kudu/kudu-side/kudu-async-side/src/main/java/com/dtstack/flink/sql/side/kudu/KuduAsyncReqRow.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -301,7 +301,7 @@ public Deferred<List<Row>> call(RowResultIterator results) throws Exception {
301301
String sideFieldName = sideFieldName1.trim();
302302
ColumnSchema columnSchema = table.getSchema().getColumn(sideFieldName);
303303
if (null != columnSchema) {
304-
KuduUtil.setMapValue(columnSchema.getType(), oneRow, sideFieldName, result);
304+
oneRow.put(sideFieldName, result.getObject(sideFieldName));
305305
}
306306
}
307307
BaseRow row = fillData(input, oneRow);

0 commit comments

Comments
 (0)