Repository: bigtop Updated Branches: refs/heads/master 194fb619f -> 8728c2824
BIGTOP-1544. User of java.io.File and check for dir existence will fail ith non-POSIX DFS(HDFS, S3, etc).. Signed-off-by: jayunit100 <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/bigtop/repo Commit: http://git-wip-us.apache.org/repos/asf/bigtop/commit/8728c282 Tree: http://git-wip-us.apache.org/repos/asf/bigtop/tree/8728c282 Diff: http://git-wip-us.apache.org/repos/asf/bigtop/diff/8728c282 Branch: refs/heads/master Commit: 8728c282424b40d43ee6480a827a161179553086 Parents: 194fb61 Author: RJ Nowling <[email protected]> Authored: Fri Nov 21 12:23:41 2014 -0500 Committer: jayunit100 <[email protected]> Committed: Fri Nov 21 20:35:01 2014 -0500 ---------------------------------------------------------------------- .../bigpetstore/spark/generator/SparkDriver.scala | 15 ++------------- 1 file changed, 2 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bigtop/blob/8728c282/bigtop-bigpetstore/bigpetstore-spark/src/main/scala/org/apache/bigpetstore/spark/generator/SparkDriver.scala ---------------------------------------------------------------------- diff --git a/bigtop-bigpetstore/bigpetstore-spark/src/main/scala/org/apache/bigpetstore/spark/generator/SparkDriver.scala b/bigtop-bigpetstore/bigpetstore-spark/src/main/scala/org/apache/bigpetstore/spark/generator/SparkDriver.scala index 1ab1057..2d7ed17 100644 --- a/bigtop-bigpetstore/bigpetstore-spark/src/main/scala/org/apache/bigpetstore/spark/generator/SparkDriver.scala +++ b/bigtop-bigpetstore/bigpetstore-spark/src/main/scala/org/apache/bigpetstore/spark/generator/SparkDriver.scala @@ -35,7 +35,7 @@ object SparkDriver { private var nCustomers: Int = -1 private var simulationLength: Double = -1.0 private var seed: Long = -1 - private var outputDir: File = new File(".") + private var outputDir: String = "" private val NPARAMS = 5 @@ -61,18 +61,7 @@ object SparkDriver { var i = 0 - outputDir = new File(args(i)) - if(! outputDir.exists()) { - System.err.println("Given path (" + args(i) + ") does not exist.\n") - printUsage() - System.exit(1) - } - - if(! outputDir.isDirectory()) { - System.err.println("Given path (" + args(i) + ") is not a directory.\n") - printUsage() - System.exit(1) - } + outputDir = args(i) i += 1 try {
