#13

Force user to configure input data path.
Xtra-Computing · May 17, 2020 · 58725b9 · 58725b9
1 parent c12f99f
commit 58725b9
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 9 deletions.
diff --git a/BriskBenchmarks/src/main/java/applications/spout/MemFileSpout.java b/BriskBenchmarks/src/main/java/applications/spout/MemFileSpout.java
@@ -76,13 +76,8 @@ public void initialize(int thread_Id, int thisTaskId, ExecutionGraph graph) {
         try {
             openFile(s);
         } catch (FileNotFoundException e) {
-
-            s = "/data/DATA/tony/data/".concat(path);
-            try {
-                openFile(s);
-            } catch (FileNotFoundException e1) {
-                e1.printStackTrace();
-            }
+            LOG.info("Please configure your input data path at ./common/src/main/resources/config/xxx.properties");
+            System.exit(-1);
         }
         long pid = OsUtils.getPID(TopologyContext.HPCMonotor);
         LOG.info("JVM PID  = " + pid);

diff --git a/common/src/main/java/applications/abstractRunner.java b/common/src/main/java/applications/abstractRunner.java
@@ -180,7 +180,7 @@ public abstract class abstractRunner {
     @Parameter(names = {"-m", "--mode"}, description = "Mode for running the topology")
     public String mode = RUN_LOCAL;
     @Parameter(names = {"-a", "--app"}, description = "The application to be executed", required = false)
-    public String application = "FraudDetection"; /*"wordcount";*/ /*"streamingAnalysis"*/
+    public String application = "WordCount"; /*"FraudDetection";*/ /*"streamingAnalysis"*/
 
     @Parameter(names = {"-t", "--Brisk.topology-name"}, required = false, description = "The name of the Brisk.topology")
     public String topologyName;

diff --git a/common/src/main/resources/config/WordCount.properties b/common/src/main/resources/config/WordCount.properties
@@ -1,4 +1,4 @@
-;=allocation.path=C:/config/wc_allocation.txt
+allocation.path=C:/config/wc_allocation.txt
 wc.spout.class=applications.spout.MemFileSpout
 batch_size.wc.spout.class=applications.spout.BatchMemFileSpout
 unix.wc.spout.path=wc/Skew01.dat