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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
