[incubator-hugegraph-toolchain] branch master updated: fix: orc data import npe (#321)

[jin]

This is an automated email from the ASF dual-hosted git repository.

jin pushed a commit to branch master
in repository 
https://gitbox.apache.org/repos/asf/incubator-hugegraph-toolchain.git


The following commit(s) were added to refs/heads/master by this push:
     new c85c5502 fix: orc data import npe (#321)
c85c5502 is described below

commit c85c5502c87efdc32f1d65e5633287e908dc1e70
Author: zhoney <zhangyi89...@126.com>
AuthorDate: Tue Sep 6 00:02:31 2022 +0800

    fix: orc data import npe (#321)
    
    Co-authored-by: ss <50285938+ssisme2...@users.noreply.github.com>
---
 .../hugegraph/loader/reader/file/OrcFileLineFetcher.java     | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git 
a/hugegraph-loader/src/main/java/com/baidu/hugegraph/loader/reader/file/OrcFileLineFetcher.java
 
b/hugegraph-loader/src/main/java/com/baidu/hugegraph/loader/reader/file/OrcFileLineFetcher.java
index e5f846d5..df6e9b9e 100644
--- 
a/hugegraph-loader/src/main/java/com/baidu/hugegraph/loader/reader/file/OrcFileLineFetcher.java
+++ 
b/hugegraph-loader/src/main/java/com/baidu/hugegraph/loader/reader/file/OrcFileLineFetcher.java
@@ -125,9 +125,15 @@ public class OrcFileLineFetcher extends FileLineFetcher {
         }
 
         this.row = this.recordReader.next(this.row);
-        Object[] values = this.inspector.getStructFieldsDataAsList(this.row)
-                                        .stream().map(Object::toString)
-                                        .toArray();
+        List<Object> data = this.inspector.getStructFieldsDataAsList(this.row);
+        Object[] values = new Object[data.size()];
+        for (int i = 0; i < data.size(); i++) {
+            if (data.get(i) == null) {
+                values[i] = "";
+            } else {
+                values[i] = data.get(i).toString();
+            }
+        }
         String rawLine = StringUtils.join(values, Constants.COMMA_STR);
 
         this.increaseOffset();