Kubernetes Job创建后Pod列表长度偶现零值及Pod标签设置问题

原因：Kubernetes创建Job后，调度器需要时间完成Pod的创建与注册流程，你在Job创建完成后立即调用list()查询，此时Pod可能还未就绪，导致查询结果为空。

解决方案：不要仅执行单次查询，而是等待Pod出现后再进行后续操作。可以借助Java Kubernetes Client的waitUntilCondition方法实现等待逻辑，或者通过循环查询加短暂延迟的方式，直到超时。

修改后的代码示例（使用waitUntilCondition）： #

// 替换原有PodList查询逻辑，等待Pod出现
PodList podList = kubernetesClient.pods().inNamespace(namespace)
    .withLabel("job-name", jobName)
    .waitUntilCondition(list -> !list.getItems().isEmpty(), JOB_TIMEOUT, TimeUnit.MINUTES);

// 后续逻辑保持不变
var pods = podList.getItems().size();
_LOGGER.info("pods created size:" + pods);
if (pods > 0) {
    var k8sPod = podList.getItems().get(0);
    var podName = k8sPod.getMetadata().getName();
    kubernetesClient.pods().inNamespace(namespace).withName(podName)
        .waitUntilCondition(pod -> {
            var podPhase = pod.getStatus().getPhase();
            // 你的业务逻辑
            return terminalPodStatus.contains(podPhase.toLowerCase());
        }, JOB_TIMEOUT, TimeUnit.MINUTES);
}
kubernetesClient.close();

备选方案（循环查询）： #

long startTime = System.currentTimeMillis();
PodList podList = null;
while (System.currentTimeMillis() - startTime < JOB_TIMEOUT.toMillis()) {
    podList = kubernetesClient.pods().inNamespace(namespace)
        .withLabel("job-name", jobName).list();
    if (!podList.getItems().isEmpty()) {
        break;
    }
    TimeUnit.SECONDS.sleep(1); // 每秒查询一次
}

if (podList == null || podList.getItems().isEmpty()) {
    _LOGGER.error("Timeout waiting for pod to be created");
    return;
}
// 后续逻辑

要给Job生成的Pod添加专属标签，需要在Job的PodTemplateSpec的Metadata中配置标签，而非仅给Job本身添加标签。当前你的createJob方法仅给Job对象设置了标签，Pod不会自动继承这些标签（仅默认继承job-name标签）。

修改后的createJob方法： #

private Job createJob(String flattenId, String authValue) {
    // 定义Pod需要的自定义标签
    Map<String, String> podLabels = new HashMap<>();
    podLabels.put("custom-label", "flatten-job-pod");
    podLabels.put("flatten-id", flattenId); // 可添加业务相关标识标签

    return new JobBuilder()
        .withApiVersion(API_VERSION)
        .withNewMetadata()
            .withName(jobName)
            .withLabels(labels) // 这是Job自身的标签
            .endMetadata()
        .withNewSpec()
            .withTtlSecondsAfterFinished(300)
            .withBackoffLimit(0)
            .withNewTemplate()
                .withNewMetadata()
                    .withAnnotations(LINKERD_INJECT_ANNOTATIONS)
                    .withLabels(podLabels) // 此处添加Pod的专属标签
                    .endMetadata()
                .withNewSpec()
                    .withServiceAccount(Constants.TEST_SERVICEACCOUNT)
                    .addNewContainer()
                        .addAllToEnv(envVars)
                        .withImage(System.getenv(BUILD_JOB_IMAGE))
                        .withName("test") // 修正原代码中的语法错误：""test → "test"
                        .withCommand("/bin/bash", "-c", "java -jar test.jar")
                        .endContainer()
                    .withRestartPolicy(RESTART_POLICY_NEVER)
                    .endSpec()
                .endTemplate()
            .endSpec()
        .build();
}

内容的提问来源于stack exchange，提问作者santosh jk