From b3d0493fdb49966e4e9cc7756dc240d29bc0022e Mon Sep 17 00:00:00 2001 From: Virushade <70288012+GWphua@users.noreply.github.com> Date: Mon, 20 Jan 2025 23:54:27 +0800 Subject: [PATCH] Fix typo in PeonCommandContext (#17645) --- .../k8s/overlord/common/PeonCommandContext.java | 14 +++++++------- .../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 30e768e47ba0..b1b5bf9ed310 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 @@ public class PeonCommandContext { - private final List comamnd; + private final List command; private final List javaOpts; private final File taskDir; private final boolean enableTls; private final int cpuMicroCore; - public PeonCommandContext(List comamnd, List javaOpts, File taskDir, int cpuMicroCore) + public PeonCommandContext(List command, List javaOpts, File taskDir, int cpuMicroCore) { - this(comamnd, javaOpts, taskDir, cpuMicroCore, false); + this(command, javaOpts, taskDir, cpuMicroCore, false); } public PeonCommandContext( - List comamnd, + List command, List 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 getComamnd() + public List getCommand() { - return comamnd; + return command; } public List 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 cc689f925f4f..1026ccb24862 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 @@ protected Container setupMainContainer( 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(