@@ -758,15 +758,6 @@ func (k *Bootstrapper) JoinCluster(cc config.ClusterConfig, n config.Node, joinC
758758 return errors .Wrapf (err , "kubeadm join" )
759759 }
760760
761- // avoid "Found multiple CRI sockets, please use --cri-socket to select one: /var/run/dockershim.sock, /var/run/crio/crio.sock" error
762- cr , err := cruntime .New (cruntime.Config {Type : cc .KubernetesConfig .ContainerRuntime , Runner : k .c , Socket : cc .KubernetesConfig .CRISocket })
763- if err != nil {
764- return errors .Wrap (err , "runtime" )
765- }
766- if sp := cr .SocketPath (); sp != "" {
767- joinCmd = fmt .Sprintf ("%s --cri-socket=%s" , joinCmd , sp )
768- }
769-
770761 if _ , err := k .c .RunCmd (exec .Command ("/bin/bash" , "-c" , "sudo systemctl daemon-reload && sudo systemctl enable kubelet && sudo systemctl start kubelet" )); err != nil {
771762 return errors .Wrap (err , "starting kubelet" )
772763 }
@@ -786,9 +777,17 @@ func (k *Bootstrapper) GenerateToken(cc config.ClusterConfig) (string, error) {
786777 joinCmd := r .Stdout .String ()
787778 joinCmd = strings .Replace (joinCmd , "kubeadm" , bsutil .InvokeKubeadm (cc .KubernetesConfig .KubernetesVersion ), 1 )
788779 joinCmd = fmt .Sprintf ("%s --ignore-preflight-errors=all" , strings .TrimSpace (joinCmd ))
789- if cc .KubernetesConfig .CRISocket != "" {
790- joinCmd = fmt .Sprintf ("%s --cri-socket %s" , joinCmd , cc .KubernetesConfig .CRISocket )
780+
781+ // avoid "Found multiple CRI sockets, please use --cri-socket to select one: /var/run/dockershim.sock, /var/run/crio/crio.sock" error
782+ cr , err := cruntime .New (cruntime.Config {Type : cc .KubernetesConfig .ContainerRuntime , Runner : k .c , Socket : cc .KubernetesConfig .CRISocket })
783+ if err != nil {
784+ klog .Errorf ("cruntime: %v" , err )
785+ }
786+ sp := cr .SocketPath ()
787+ if sp == "" {
788+ sp = kconst .DefaultDockerCRISocket
791789 }
790+ joinCmd = fmt .Sprintf ("%s --cri-socket %s" , joinCmd , sp )
792791
793792 return joinCmd , nil
794793}
0 commit comments