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