aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/scala/parallelai/spyglass/hbase/example
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/scala/parallelai/spyglass/hbase/example')
-rw-r--r--src/main/scala/parallelai/spyglass/hbase/example/HBaseExampleRunner.scala6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/main/scala/parallelai/spyglass/hbase/example/HBaseExampleRunner.scala b/src/main/scala/parallelai/spyglass/hbase/example/HBaseExampleRunner.scala
index d6b762e..890d2be 100644
--- a/src/main/scala/parallelai/spyglass/hbase/example/HBaseExampleRunner.scala
+++ b/src/main/scala/parallelai/spyglass/hbase/example/HBaseExampleRunner.scala
@@ -25,10 +25,14 @@ object HBaseExampleRunner extends App {
}
case _ => ""
}
+
+ val quorum = System.getenv("BIGDATA_QUORUM_NAMES")
+ assert (quorum != null, {"Environment Variable BIGDATA_QUORUM_NAMES is undefined or Null"})
+ println( "Quorum is [%s]".format(quorum) )
val output = "HBaseTest.%s.tsv"
Tool.main(Array(classOf[HBaseExample].getName, modeString, "--app.conf.path", appPath,
- "--output", output, "--debug", "true", "--job.lib.path", jobLibPath ))
+ "--output", output, "--debug", "true", "--job.lib.path", jobLibPath, "--quorum", quorum ))
} \ No newline at end of file