Merge pull request #1727 from duanmengkk/master

Add namespace propagated waiting check in the SynchronizedBeforeSuite

test/e2e/aggregatedapi_test.go

@@ -88,9 +88,6 @@ var _ = ginkgo.Describe("Aggregated Kubernetes API Endpoint testing", func() {
 			})
 
 			ginkgo.BeforeEach(func() {
-				// Wait for namespace present before creating resources in it.
-				framework.WaitNamespacePresentOnCluster(member1, tomServiceAccount.Namespace)
-
 				klog.Infof("Create ServiceAccount(%s) in the cluster(%s)", klog.KObj(tomServiceAccount).String(), member1)
 				framework.CreateServiceAccount(clusterClient, tomServiceAccount)
 				ginkgo.DeferCleanup(func() {

test/e2e/porting_workloads_test.go

@@ -52,11 +52,6 @@ var _ = ginkgo.Describe("porting workloads testing", func() {
 				"Creating deployment(%s/%s) on the member cluster %s first to simulate a scenario where the target cluster already has a deployment with the same name",
 				deploymentNamespace, deploymentName, member1,
 			)
-			gomega.Eventually(func() bool {
-				klog.Infof("Waiting for namespace(%s) to exist on cluster %s", testNamespace, member1)
-				_, err := member1Client.CoreV1().Namespaces().Get(context.TODO(), testNamespace, metav1.GetOptions{})
-				return err == nil
-			}, pollTimeout, pollInterval).Should(gomega.Equal(true))
 			framework.CreateDeployment(member1Client, deployment)
 
 			framework.CreatePropagationPolicy(karmadaClient, policy)

test/e2e/suite_test.go

@@ -108,6 +108,8 @@ var _ = ginkgo.SynchronizedBeforeSuite(func() []byte {
 	testNamespace = fmt.Sprintf("karmadatest-%s", rand.String(RandomStrLength))
 	err = setupTestNamespace(testNamespace, kubeClient)
 	gomega.Expect(err).ShouldNot(gomega.HaveOccurred())
+
+	framework.WaitNamespacePresentOnClusters(framework.ClusterNames(), testNamespace)
 })
 
 var _ = ginkgo.SynchronizedAfterSuite(func() {