From 4923ad9bb7bb8f26b78d52e9e945d0abf1a67467 Mon Sep 17 00:00:00 2001
From: wgzhao <wgzhao@gmail.com>
Date: Thu, 5 Sep 2024 15:18:42 +0800
Subject: [PATCH] [bugfix][plugin][hdfswriter] Fix NullPointerException when
writing Parquet file with null string field value
Add missing 'continue' statement to handle null string field values and prevent NullPointerException during Parquet file writing, fix #1104
---
.../com/wgzhao/addax/plugin/writer/hdfswriter/HdfsHelper.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/plugin/writer/hdfswriter/src/main/java/com/wgzhao/addax/plugin/writer/hdfswriter/HdfsHelper.java b/plugin/writer/hdfswriter/src/main/java/com/wgzhao/addax/plugin/writer/hdfswriter/HdfsHelper.java
index 7020f09e7..9c2a6a27e 100644
--- a/plugin/writer/hdfswriter/src/main/java/com/wgzhao/addax/plugin/writer/hdfswriter/HdfsHelper.java
+++ b/plugin/writer/hdfswriter/src/main/java/com/wgzhao/addax/plugin/writer/hdfswriter/HdfsHelper.java
@@ -246,9 +246,9 @@ public static Group transportParRecord(
String typename = columns.get(i).getString(Key.TYPE).toUpperCase();
if (null == column || column.getRawData() == null) {
group.append(colName, "");
+ continue;
}
SupportHiveDataType columnType = SupportHiveDataType.valueOf(typename);
- assert column != null;
switch (columnType) {
case INT:
case INTEGER: