@@ -30,6 +30,7 @@ import (
30
30
"strings"
31
31
"time"
32
32
33
+ "github.com/mozillazg/go-pinyin"
33
34
"github.com/pkg/errors"
34
35
"go.uber.org/zap"
35
36
"gopkg.in/yaml.v2"
@@ -138,6 +139,26 @@ func getJobLabels(jobLabel *JobLabel) map[string]string {
138
139
return retMap
139
140
}
140
141
142
+ func getJobContainerName (name string ) string {
143
+ pyArgs := pinyin .NewArgs ()
144
+ pyArgs .Fallback = func (r rune , a pinyin.Args ) []string {
145
+ return []string {string (r )}
146
+ }
147
+
148
+ res := pinyin .Pinyin (name , pyArgs )
149
+
150
+ pinyins := make ([]string , 0 )
151
+ for _ , py := range res {
152
+ pinyins = append (pinyins , strings .Join (py , "" ))
153
+ }
154
+
155
+ resp := strings .Join (pinyins , "" )
156
+ if len (resp ) > 63 {
157
+ return resp [:63 ]
158
+ }
159
+ return resp
160
+ }
161
+
141
162
func createJobConfigMap (namespace , jobName string , jobLabel * JobLabel , jobCtx string , kubeClient crClient.Client ) error {
142
163
cm := & corev1.ConfigMap {
143
164
ObjectMeta : metav1.ObjectMeta {
@@ -334,7 +355,7 @@ echo $result > %s
334
355
Containers : []corev1.Container {
335
356
{
336
357
ImagePullPolicy : corev1 .PullAlways ,
337
- Name : jobTask .Name ,
358
+ Name : getJobContainerName ( jobTask .Name ) ,
338
359
Image : jobTaskSpec .Plugin .Image ,
339
360
Args : jobTaskSpec .Plugin .Args ,
340
361
Command : jobTaskSpec .Plugin .Cmds ,
@@ -459,7 +480,7 @@ func buildJob(jobType, jobImage, jobName, clusterID, currentNamespace string, re
459
480
Containers : []corev1.Container {
460
481
{
461
482
ImagePullPolicy : corev1 .PullAlways ,
462
- Name : strings .ReplaceAll (jobTask .Name , "_" , "-" ),
483
+ Name : getJobContainerName ( strings .ReplaceAll (jobTask .Name , "_" , "-" ) ),
463
484
Image : jobImage ,
464
485
Command : []string {"/bin/sh" , "-c" },
465
486
Args : []string {jobExecutorBootingScript },
0 commit comments