move exec class change to another pr

Alluxio · Aug 30, 2023 · 4cb7ac9 · 4cb7ac9
1 parent 56e6f61
commit 4cb7ac9
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 7 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
@@ -125,12 +125,10 @@ private Map<String, Object> getUfsConf(String ufsUri, RunTaskContext runTaskCont
   @Override
   public String runTask(StressBenchConfig config, ArrayList<String> args,
       RunTaskContext runTaskContext) throws Exception {
-    List<String> command = new ArrayList<>(5 + config.getArgs().size());
+    List<String> command = new ArrayList<>(3 + config.getArgs().size());
     command.add(Configuration.get(PropertyKey.HOME) + "/bin/alluxio");
-    command.add("exec");
-    command.add("class");
+    command.add("runClass");
     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,10 +193,8 @@ 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("exec");
-      command.add("class");
+      command.add("runClass");
       command.add(className);
-      command.add("--");
       command.addAll(Arrays.asList(args));
       command.add(BaseParameters.IN_PROCESS_FLAG);
       command.addAll(mBaseParameters.mJavaOpts.stream().map(String::trim)