diff --git a/e2e/fleet_attachedcluster_test.go b/e2e/fleet_attachedcluster_test.go
index 4d06c223..5bb6cd69 100644
--- a/e2e/fleet_attachedcluster_test.go
+++ b/e2e/fleet_attachedcluster_test.go
@@ -59,7 +59,7 @@ var _ = ginkgo.Describe("[AttachedClusters] AttachedClusters testing", func() {
 
 	ginkgo.It("Create Fleet", func() {
 		// create fleet and checkout fleet status
-		fleetCreateErr := resources.CreateFleet(kuratorClient, fleet)
+		fleetCreateErr := resources.CreateOrUpdateFleet(kuratorClient, fleet)
 		gomega.Expect(fleetCreateErr).ShouldNot(gomega.HaveOccurred())
 		resources.WaitFleetFitWith(kuratorClient, namespace, fleetname, func(fleet *fleetv1a1.Fleet) bool {
 			return fleet.Status.Phase == fleetv1a1.ReadyPhase
diff --git a/e2e/suite_test.go b/e2e/suite_test.go
index a1644087..6619e8bb 100644
--- a/e2e/suite_test.go
+++ b/e2e/suite_test.go
@@ -92,10 +92,10 @@ var _ = ginkgo.SynchronizedBeforeSuite(func() []byte {
 	}
 	attachedcluster = resources.NewAttachedCluster(namespace, memberClusterName, secretKeyRef)
 
-	secretCreateErr := resources.CreateSecret(kubeClient, secret)
+	secretCreateErr := resources.CreateOrUpdateSecret(kubeClient, secret)
 	gomega.Expect(secretCreateErr).ShouldNot(gomega.HaveOccurred())
 
-	attachedCreateErr := resources.CreateAttachedCluster(kuratorClient, attachedcluster)
+	attachedCreateErr := resources.CreateOrUpdateAttachedCluster(kuratorClient, attachedcluster)
 	gomega.Expect(attachedCreateErr).ShouldNot(gomega.HaveOccurred())
 	resources.WaitAttachedClusterFitWith(kuratorClient, namespace, memberClusterName, func(attachedCluster *clusterv1a1.AttachedCluster) bool {
 		return attachedCluster.Status.Ready