diff --git a/test/e2e_kubeadm/nodes_test.go b/test/e2e_kubeadm/nodes_test.go index dbf1d4eb3fa..9d94b3a89a0 100644 --- a/test/e2e_kubeadm/nodes_test.go +++ b/test/e2e_kubeadm/nodes_test.go @@ -18,6 +18,7 @@ package kubeadm import ( "context" + rbacv1 "k8s.io/api/rbac/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/kubernetes/test/e2e/framework" @@ -51,9 +52,11 @@ var _ = Describe("nodes", func() { List(context.TODO(), metav1.ListOptions{}) framework.ExpectNoError(err, "error reading nodes") - // checks that the nodes have the CRI annotation + // Checks that the nodes have the CRI socket annotation + // and that it is prefixed with a URL scheme for _, node := range nodes.Items { gomega.Expect(node.Annotations).To(gomega.HaveKey(nodesCRISocketAnnotation)) + gomega.Expect(node.Annotations[nodesCRISocketAnnotation]).To(gomega.HavePrefix("unix://")) } })