使用Fabric8 Kubernetes Client手动触发CronJob遇字段错误求助

错误信息 #

Caused by: io.fabric8.kubernetes.client.KubernetesClientException: Failure executing: POST at: https://172.20.0.1:443/apis/batch/v1/namespaces/engineering/jobs. Message: Job.batch "app-chat-manual-947171" is invalid: spec.template.spec.containers[0].name: Required value. Received status: Status(apiVersion=v1, code=422, details=StatusDetails(causes=[StatusCause(field=spec.template.spec.containers[0].name, message=Required value, reason=FieldValueRequired, additionalProperties={})], group=batch, kind=Job, name=app-chat-manual-947171, retryAfterSeconds=null, uid=null, additionalProperties={}), kind=Status, message=Job.batch "app-chat-manual-947171" is invalid: spec.template.spec.containers[0].name: Required value, metadata=ListMeta(_continue=null, remainingItemCount=null, resourceVersion=null, selfLink=null, additionalProperties={}), reason=Invalid, status=Failure, additionalProperties={}).

Maven依赖 #

<dependency>
    <groupId>io.fabric8</groupId>
    <artifactId>kubernetes-client</artifactId>
    <version>6.3.1</version>
</dependency>

现有Java代码 #

public static void triggerCronjob(String cronjobName, String applicableNamespace) {
    KubernetesClient kubernetesClient = new KubernetesClientBuilder().build();

    final String podName = String.format("%s-manual-%s", cronjobName.length() > 38 ? cronjobName.substring(0, 38) : cronjobName,
            new Random().nextInt(999999));

    System.out.println("triggerCronjob method invoked, applicableNamespace: " + applicableNamespace
            + ", cronjobName: " + cronjobName + ", podName: " + podName);

    Job job = new JobBuilder()
            .withApiVersion("batch/v1")
            .withNewMetadata()
            .withName(podName)
            .endMetadata()
            .withNewSpec()
            .withBackoffLimit(4)
            .withNewTemplate()
            .withNewSpec()
            .addNewContainer()
            .withName(podName)
            .withImage("perl")
            .withCommand("perl", "-Mbignum=bpi", "-wle", "print bpi(2000)")
            .endContainer()
            .withRestartPolicy("Never")
            .endSpec()
            .endTemplate()
            .endSpec().build();

    kubernetesClient.batch().v1().jobs().inNamespace(applicableNamespace).createOrReplace(job);
    kubernetesClient.close();
    System.out.println("CronJob triggered: applicableNamespace: " + applicableNamespace + ", cronjob name: " + cronjobName);
}

错误原因 #

你复用podName作为容器名称，但podName的生成规则可能导致名称过长（超过Kubernetes允许的容器名称最大长度63字符），或格式不符合DNS子域名规范，最终导致容器名称未被正确设置，触发必填项缺失错误。

修复步骤 #

1. 单独生成符合规范的容器名称：容器名称需满足DNS子域名格式，长度不超过63字符，建议使用简短且有意义的名称。
2. 可选：基于现有CronJob模板创建Job：如果目标是触发指定CronJob的任务，直接复用CronJob的Pod模板更准确，避免手动构建Job时出现配置错误。

修复后的代码（手动构建Job版本） #

public static void triggerCronjob(String cronjobName, String applicableNamespace) {
    KubernetesClient kubernetesClient = new KubernetesClientBuilder().build();

    // 生成符合规范的Job名称（最长63字符）
    final String jobName = String.format("%s-manual-%d", 
            cronjobName.length() > 38 ? cronjobName.substring(0, 38) : cronjobName,
            new Random().nextInt(999999));
    // 生成简短的容器名称，避免过长
    final String containerName = String.format("%s-container", 
            cronjobName.length() > 15 ? cronjobName.substring(0, 15) : cronjobName);

    System.out.println("triggerCronjob method invoked, applicableNamespace: " + applicableNamespace
            + ", cronjobName: " + cronjobName + ", jobName: " + jobName);

    Job job = new JobBuilder()
            .withApiVersion("batch/v1")
            .withNewMetadata()
            .withName(jobName)
            .endMetadata()
            .withNewSpec()
            .withBackoffLimit(4)
            .withNewTemplate()
            .withNewSpec()
            .addNewContainer()
            .withName(containerName) // 使用单独生成的短容器名称
            .withImage("perl")
            .withCommand("perl", "-Mbignum=bpi", "-wle", "print bpi(2000)")
            .endContainer()
            .withRestartPolicy("Never")
            .endSpec()
            .endTemplate()
            .endSpec().build();

    kubernetesClient.batch().v1().jobs().inNamespace(applicableNamespace).createOrReplace(job);
    kubernetesClient.close();
    System.out.println("Job created successfully: applicableNamespace: " + applicableNamespace + ", job name: " + jobName);
}

更优方案（基于现有CronJob生成Job） #

如果目标是触发指定CronJob的任务，推荐直接获取CronJob的模板来创建Job，完全复用CronJob的配置，避免手动构建的错误：

public static void triggerExistingCronjob(String cronjobName, String applicableNamespace) {
    KubernetesClient kubernetesClient = new KubernetesClientBuilder().build();

    // 获取指定的CronJob
    CronJob cronJob = kubernetesClient.batch().v1().cronjobs()
            .inNamespace(applicableNamespace)
            .withName(cronjobName)
            .get();

    if (cronJob == null) {
        System.out.println("CronJob not found: " + cronjobName + " in namespace " + applicableNamespace);
        kubernetesClient.close();
        return;
    }

    // 生成Job名称
    final String jobName = String.format("%s-manual-%d", 
            cronjobName.length() > 38 ? cronjobName.substring(0, 38) : cronjobName,
            new Random().nextInt(999999));

    // 基于CronJob的模板创建Job
    Job job = new JobBuilder()
            .withApiVersion("batch/v1")
            .withNewMetadata()
            .withName(jobName)
            .endMetadata()
            .withNewSpec()
            .withBackoffLimit(cronJob.getSpec().getJobTemplate().getSpec().getBackoffLimit())
            .withTemplate(cronJob.getSpec().getJobTemplate().getSpec().getTemplate())
            .endSpec()
            .build();

    kubernetesClient.batch().v1().jobs().inNamespace(applicableNamespace).createOrReplace(job);
    kubernetesClient.close();
    System.out.println("Triggered CronJob successfully: applicableNamespace: " + applicableNamespace + ", cronjob name: " + cronjobName + ", job name: " + jobName);
}

内容的提问来源于stack exchange，提问作者Ali Taha