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 index 38796a45c537..2c45ccf68ba7 100644 --- 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 args, RunTaskContext runTaskContext) throws Exception { List 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 index 7cd051dfeef5..e4e637edfdb6 100644 --- 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 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 index 3c2238bab7fd..f4de122c0f9c 100644 --- 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 index 4ef16705ef9f..262125ffd833 100644 --- 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" ));