replace runClass with exec class

Alluxio · Aug 22, 2023 · 17088d6 · 17088d6
1 parent 0cca190
commit 17088d6
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 6 deletions.
diff --git a/dora/job/server/src/main/java/alluxio/job/plan/stress/StressBenchDefinition.java b/dora/job/server/src/main/java/alluxio/job/plan/stress/StressBenchDefinition.java
@@ -127,8 +127,10 @@ public String runTask(StressBenchConfig config, ArrayList<String> args,
       RunTaskContext runTaskContext) throws Exception {
     List<String> command = new ArrayList<>(3 + config.getArgs().size());
     command.add(Configuration.get(PropertyKey.HOME) + "/bin/alluxio");
-    command.add("runClass");
+    command.add("exec");
+    command.add("class");
     command.add(config.getClassName());
+    command.add("--");
 
     // the cluster will run distributed tasks
     command.add(BaseParameters.DISTRIBUTED_FLAG);

diff --git a/dora/stress/shell/src/main/java/alluxio/stress/cli/Benchmark.java b/dora/stress/shell/src/main/java/alluxio/stress/cli/Benchmark.java
@@ -193,8 +193,10 @@ protected String runSingleTask(String[] args) throws Exception {
       // Spawn a new process
       List<String> command = new ArrayList<>();
       command.add(conf.get(PropertyKey.HOME) + "/bin/alluxio");
-      command.add("runClass");
+      command.add("exec");
+      command.add("class");
       command.add(className);
+      command.add("--");
       command.addAll(Arrays.asList(args));
       command.add(BaseParameters.IN_PROCESS_FLAG);
       command.addAll(mBaseParameters.mJavaOpts.stream().map(String::trim)

diff --git a/dora/stress/shell/src/main/java/alluxio/stress/cli/client/StressClientIOBench.java b/dora/stress/shell/src/main/java/alluxio/stress/cli/client/StressClientIOBench.java
@@ -103,10 +103,10 @@ public String getBenchDescription() {
         "# This test will run create a 500MB file with block size 15KB on 1 worker,",
         "# then test the ReadArray operation for 30s and calculate the throughput after 10s "
             + "warmup.",
-        "$ bin/alluxio runClass alluxio.stress.cli.client.StressClientIOBench --operation Write "
-            + "--base alluxio:///stress-client-io-base --file-size 500m --buffer-size 64k "
+        "$ bin/alluxio exec class alluxio.stress.cli.client.StressClientIOBench -- --operation "
+            + "Write --base alluxio:///stress-client-io-base --file-size 500m --buffer-size 64k "
             + "--block-size 16k --write-num-workers 1 --cluster --cluster-limit 1",
-        "$ bin/alluxio runClass alluxio.stress.cli.client.StressClientIOBench --operation "
+        "$ bin/alluxio exec class alluxio.stress.cli.client.StressClientIOBench -- --operation "
             + "ReadArray --base alluxio:///stress-client-io-base --file-size 500m --buffer-size "
             + "64k --block-size 16k --warmup 10s --duration 30s --write-num-workers 1 --cluster "
             + "--cluster-limit 1\n"));

diff --git a/dora/stress/shell/src/main/java/alluxio/stress/cli/worker/StressWorkerBench.java b/dora/stress/shell/src/main/java/alluxio/stress/cli/worker/StressWorkerBench.java
@@ -123,7 +123,7 @@ public String getBenchDescription() {
             + "be prepared for each test thread."
             + "# The threads will keeping reading for 30s including a 10s warmup."
             + "# So the result captures I/O performance from the last 20s.",
-        "$ bin/alluxio runClass alluxio.stress.cli.worker.StressWorkerBench \\\n"
+        "$ bin/alluxio exec class alluxio.stress.cli.worker.StressWorkerBench -- \\\n"
             + "--threads 32 --base alluxio:///stress-worker-base --file-size 100m \\\n"
             + "--warmup 10s --duration 30s --cluster\n"
     ));