[incubator-hugegraph-toolchain] branch master updated: fix: spark row split by delimiter failed (#328)

[ji...@apache.org]

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 9d34f4aa fix: spark row split by delimiter failed (#328)
9d34f4aa is described below

commit 9d34f4aaa9debf51f1f8b433d579d6fe8bd9b110
Author: Simon Cheung <mi...@apache.org>
AuthorDate: Wed Aug 31 14:44:31 2022 +0800

    fix: spark row split by delimiter failed (#328)
---
 .../java/com/baidu/hugegraph/loader/spark/HugeGraphSparkLoader.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/hugegraph-loader/src/main/java/com/baidu/hugegraph/loader/spark/HugeGraphSparkLoader.java b/hugegraph-loader/src/main/java/com/baidu/hugegraph/loader/spark/HugeGraphSparkLoader.java
index 08396dad..ec94cf19 100644
--- a/hugegraph-loader/src/main/java/com/baidu/hugegraph/loader/spark/HugeGraphSparkLoader.java
+++ b/hugegraph-loader/src/main/java/com/baidu/hugegraph/loader/spark/HugeGraphSparkLoader.java
@@ -205,9 +205,9 @@ public class HugeGraphSparkLoader implements Serializable {
             case FILE:
             case HDFS:
                 FileSource fileSource = struct.input().asFileSource();
+                String delimiter = fileSource.delimiter();
                 elements = builder.build(fileSource.header(),
-                                         row.mkString()
-                                            .split(fileSource.delimiter()));
+                                         row.mkString(delimiter).split(delimiter));
                 break;
             case JDBC:
                 Object[] structFields = JavaConverters.asJavaCollection(row.schema().toList())