From 06041bb474e94ecf44de437b8f50a54b3dc191dc Mon Sep 17 00:00:00 2001 From: "alan578.zhao" <956322745@qq.com> Date: Thu, 17 Oct 2024 20:12:30 +0800 Subject: [PATCH] #629 Hstore support bulkload --- hugegraph-loader/assembly/static/bin/get-params.sh | 2 +- .../hugegraph/loader/direct/loader/HStoreDirectLoader.java | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/hugegraph-loader/assembly/static/bin/get-params.sh b/hugegraph-loader/assembly/static/bin/get-params.sh index 06d5d5920..3b160459d 100644 --- a/hugegraph-loader/assembly/static/bin/get-params.sh +++ b/hugegraph-loader/assembly/static/bin/get-params.sh @@ -28,7 +28,7 @@ function get_params() { --max-conn | --max-conn-per-route | --batch-size | --max-parse-errors | --max-insert-errors | \ --timeout | --shutdown-timeout | --retry-times | --retry-interval | --check-vertex | \ --print-progress | --dry-run | --sink-type | --vertex-partitions | --edge-partitions | --backend | \ - --pd-address | --pd-rest-port | --hdfs-uri \ + --pd-address | --pd-rest-port | --hdfs-uri |--max-download-rate \ | --help ) HUGEGRAPH_PARAMS="$HUGEGRAPH_PARAMS $1 $2" shift 2 diff --git a/hugegraph-loader/src/main/java/org/apache/hugegraph/loader/direct/loader/HStoreDirectLoader.java b/hugegraph-loader/src/main/java/org/apache/hugegraph/loader/direct/loader/HStoreDirectLoader.java index 7f3e25710..bff13ce6a 100644 --- a/hugegraph-loader/src/main/java/org/apache/hugegraph/loader/direct/loader/HStoreDirectLoader.java +++ b/hugegraph-loader/src/main/java/org/apache/hugegraph/loader/direct/loader/HStoreDirectLoader.java @@ -163,7 +163,6 @@ private String getSSTFilePath(Configuration conf) throws IOException { LOG.info("\n delete sstFile path \n"); fs.delete(hfileGenPath, true); } -// fs.close(); return pathStr; }