Repository: incubator-s2graph Updated Branches: refs/heads/master aeaff3fc6 -> 042410d5b
fix null pointer error on Bulk Loader. Project: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/commit/4e3fd9c5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/tree/4e3fd9c5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/diff/4e3fd9c5 Branch: refs/heads/master Commit: 4e3fd9c5f1090eb112061a0aeba6bb3e0ebc083c Parents: f1e6be2 Author: DO YUNG YOON <[email protected]> Authored: Mon Feb 26 11:23:10 2018 +0900 Committer: DO YUNG YOON <[email protected]> Committed: Mon Feb 26 11:23:10 2018 +0900 ---------------------------------------------------------------------- .../org/apache/s2graph/loader/subscriber/TransferToHFile.scala | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/4e3fd9c5/loader/src/main/scala/org/apache/s2graph/loader/subscriber/TransferToHFile.scala ---------------------------------------------------------------------- diff --git a/loader/src/main/scala/org/apache/s2graph/loader/subscriber/TransferToHFile.scala b/loader/src/main/scala/org/apache/s2graph/loader/subscriber/TransferToHFile.scala index 6aaf6fd..4eb9898 100644 --- a/loader/src/main/scala/org/apache/s2graph/loader/subscriber/TransferToHFile.scala +++ b/loader/src/main/scala/org/apache/s2graph/loader/subscriber/TransferToHFile.scala @@ -168,6 +168,8 @@ object TransferToHFile extends SparkApp { val sc = new SparkContext(conf) + val phase = System.getProperty("phase") + GraphSubscriberHelper.apply(phase, dbUrl, "none", "none") GraphSubscriberHelper.management.createStorageTable(zkQuorum, tableName, List("e", "v"), maxHFilePerResionServer, None, compressionAlgorithm) /* set up hbase init */
