diff --git a/test/integration_test/common_test.go b/test/integration_test/common_test.go
index dd85f36b15..3819d855f1 100644
--- a/test/integration_test/common_test.go
+++ b/test/integration_test/common_test.go
@@ -115,7 +115,7 @@ const (
 	zoneScore   = 25
 	regionScore = 10
 
-	defaultWaitTimeout       time.Duration = 15 * time.Minute
+	defaultWaitTimeout       time.Duration = 20 * time.Minute
 	clusterDomainWaitTimeout time.Duration = 15 * time.Minute
 	groupSnapshotWaitTimeout time.Duration = 15 * time.Minute
 	defaultWaitInterval      time.Duration = 10 * time.Second
diff --git a/test/integration_test/operator_test.go b/test/integration_test/operator_test.go
index 48e6a81dfc..e227fb0368 100644
--- a/test/integration_test/operator_test.go
+++ b/test/integration_test/operator_test.go
@@ -66,9 +66,11 @@ func validateAndDestroyCrMigration(t *testing.T, appName string, appPath string)
 	log.FailOnError(t, err, "failed to set kubeconfig to source cluster: %v", err)
 
 	appData := asyncdr.GetAppData(appName)
-	podsCreated, err := asyncdr.PrepareApp(appName, appPath)
+	_, err = asyncdr.PrepareApp(appName, appPath)
 	log.FailOnError(t, err, "Error creating pods")
 
+	podsCreated, err := core.Instance().GetPods(appData.Ns, nil)
+	log.FailOnError(t, err, "Error getting podlist, err: %v", err)
 	podsCreatedLen := len(podsCreated.Items)
 	log.InfoD("podsCreatedLen: %v", podsCreatedLen)
 	sourceClusterConfigPath, err := getClusterConfigPath(srcConfig)