根本原因是 kube-batch 不自动处理原生 job，需显式启用 job 插件并添加注解 plugins.kube-batch.scheduling.k8s.io/job: "true"；同时须配置 podgroup、queue 及 schedulername="kube-batch" 形成闭环。
为什么 kube-batch 的 Job 一直 Pending，而原生 Kubernetes Job 能正常调度？
根本原因在于 kube-batch 不处理 Job 资源本身，它只调度被插件（如 job 插件）显式支持的、带特定标签或注解的自定义资源。Golang 程序提交的原生 batch/v1 Job 默认不被 kube-batch 拦截。
实操建议：
立即学习“go语言免费学习笔记（深入）”；
- 确认你部署的 kube-batch 启用了
job插件（检查 ConfigMap 中plugins字段是否含"job"） - 给 Job 加上
plugins.kube-batch.scheduling.k8s.io/job: "true"注解，这是触发 kube-batch 处理的开关 - Golang 客户端创建 Job 时，必须在
ObjectMeta.Annotations中写入该注解，不能只靠 YAML 配置 - 别依赖
spec.parallelism自动触发——kube-batch 不看这个字段，只认注解 + 插件启用状态
如何用 client-go 正确提交一个被 kube-batch 调度的 Job？
关键不是“调用哪个函数”，而是构造出符合 kube-batch 语义的资源对象。client-go 本身无特殊封装，全靠你填对字段。
实操建议：
立即学习“go语言免费学习笔记（深入）”；
- 使用
batchv1.Job类型，不要尝试用 kube-batch 自定义 CRD（如PodGroup或Task）替代 Job - 必须设置
Annotations["plugins.kube-batch.scheduling.k8s.io/job"] = "true" - 如果需要队列隔离，加上
Annotations["scheduling.k8s.io/group-name"] = "my-queue"，并确保该QueueCR 已存在且status.state == "Active" - 注意：kube-batch v0.22+ 要求
spec.template.spec.schedulerName显式设为"kube-batch"，否则 fallback 到 default-scheduler
示例片段（非完整）：
job := &batchv1.Job{
ObjectMeta: metav1.ObjectMeta{
GenerateName: "demo-job-",
Annotations: map[string]string{
"plugins.kube-batch.scheduling.k8s.io/job": "true",
"scheduling.k8s.io/group-name": "default",
},
},
Spec: batchv1.JobSpec{
SchedulerName: "kube-batch",
Template: corev1.PodTemplateSpec{
Spec: corev1.PodSpec{
Containers: []corev1.Container{{Name: "main", Image: "busybox:1.35"}},
RestartPolicy: corev1.RestartPolicyNever,
},
},
},
}
PodGroup 创建失败或状态卡在 Pending，常见原因有哪些？
PodGroup 是 kube-batch 实现队列/配额/最小启动数等能力的基础设施，但它的生命周期独立于 Job，容易因配置错位导致整个调度链路中断。
实操建议：
立即学习“go语言免费学习笔记（深入）”；
- 检查
PodGroup的spec.minMember是否大于实际 Job 的parallelism或completions，这会导致永远无法满足“就绪条件” - 确认
PodGroup的namespace与 Job 相同——kube-batch 不跨 namespace 关联 PodGroup 和 Job - 查看
kubectl get podgroup -n NAMESPACE输出，若STATUS为Pending，大概率是没配Queue或对应Queue的spec.weight为 0 - 别在 Golang 代码里反复 Create 同名
PodGroup，它不支持幂等更新，重复创建会报AlreadyExists错误
为什么本地开发时调度延迟高，甚至任务一直不分配 Pod？
这不是 Golang 代码的问题，而是 kube-batch 的调度周期和事件监听机制在低负载或测试环境下的典型表现。
实操建议：
立即学习“go语言免费学习笔记（深入）”；
- 调大 kube-batch 的
--scheduler-name对应组件的--update-period参数（默认 1s），但更关键是检查--enable-gang-scheduling是否开启——关掉它可大幅降低单次调度延迟（gang 模式需等待全部 Pod 就绪） - 确认你的 Job Pod 模板里没有未满足的节点亲和性（
nodeSelector）、污点容忍（Tolerations）或资源请求（resources.requests）远超集群空闲量 - 用
kubectl describe podgroup NAME查Events，比看 Job Events 更早暴露调度阻塞点（比如 “Failed to find Queue”） - 避免在 minikube 或 kind 单节点集群中测试多 Pod 并发场景——kube-batch 的 gang 调度逻辑可能因节点资源碎片化而反复重试
真正卡住的地方往往不在 Go 代码怎么写，而在 PodGroup、Queue、Job 注解三者之间有没有形成闭环。漏掉任意一环，kube-batch 就当它不存在。
