This is an automated email from the ASF dual-hosted git repository.

kfaraz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git


The following commit(s) were added to refs/heads/master by this push:
     new b3d0493fdb4 Fix typo in PeonCommandContext (#17645)
b3d0493fdb4 is described below

commit b3d0493fdb49966e4e9cc7756dc240d29bc0022e
Author: Virushade <70288012+gwp...@users.noreply.github.com>
AuthorDate: Mon Jan 20 23:54:27 2025 +0800

    Fix typo in PeonCommandContext (#17645)
---
 .../druid/k8s/overlord/common/PeonCommandContext.java      | 14 +++++++-------
 .../druid/k8s/overlord/taskadapter/K8sTaskAdapter.java     |  2 +-
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git 
a/extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/common/PeonCommandContext.java
 
b/extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/common/PeonCommandContext.java
index 30e768e47ba..b1b5bf9ed31 100644
--- 
a/extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/common/PeonCommandContext.java
+++ 
b/extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/common/PeonCommandContext.java
@@ -27,35 +27,35 @@ import java.util.List;
 public class PeonCommandContext
 {
 
-  private final List<String> comamnd;
+  private final List<String> command;
   private final List<String> javaOpts;
   private final File taskDir;
   private final boolean enableTls;
   private final int cpuMicroCore;
 
-  public PeonCommandContext(List<String> comamnd, List<String> javaOpts, File 
taskDir, int cpuMicroCore)
+  public PeonCommandContext(List<String> command, List<String> javaOpts, File 
taskDir, int cpuMicroCore)
   {
-    this(comamnd, javaOpts, taskDir, cpuMicroCore, false);
+    this(command, javaOpts, taskDir, cpuMicroCore, false);
   }
 
   public PeonCommandContext(
-      List<String> comamnd,
+      List<String> command,
       List<String> javaOpts,
       File taskDir,
       int cpuMicroCore,
       boolean enableTls
   )
   {
-    this.comamnd = comamnd;
+    this.command = command;
     this.javaOpts = javaOpts;
     this.taskDir = taskDir;
     this.cpuMicroCore = cpuMicroCore;
     this.enableTls = enableTls;
   }
 
-  public List<String> getComamnd()
+  public List<String> getCommand()
   {
-    return comamnd;
+    return command;
   }
 
   public List<String> getJavaOpts()
diff --git 
a/extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/taskadapter/K8sTaskAdapter.java
 
b/extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/taskadapter/K8sTaskAdapter.java
index cc689f925f4..1026ccb2486 100644
--- 
a/extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/taskadapter/K8sTaskAdapter.java
+++ 
b/extensions-core/kubernetes-overlord-extensions/src/main/java/org/apache/druid/k8s/overlord/taskadapter/K8sTaskAdapter.java
@@ -316,7 +316,7 @@ public abstract class K8sTaskAdapter implements TaskAdapter
     addEnvironmentVariables(mainContainer, context, taskContents);
 
     mainContainer.setCommand(mainCommand);
-    mainContainer.setArgs(Collections.singletonList(Joiner.on(" 
").join(context.getComamnd())));
+    mainContainer.setArgs(Collections.singletonList(Joiner.on(" 
").join(context.getCommand())));
 
     mainContainer.setName("main");
     ResourceRequirements requirements = getResourceRequirements(


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@druid.apache.org
For additional commands, e-mail: commits-h...@druid.apache.org

Reply via email to