diff --git a/tests/e2e/tidbcluster/tidbcluster.go b/tests/e2e/tidbcluster/tidbcluster.go index de6ee8ff7f..7402637aca 100644 --- a/tests/e2e/tidbcluster/tidbcluster.go +++ b/tests/e2e/tidbcluster/tidbcluster.go @@ -2021,6 +2021,16 @@ var _ = ginkgo.Describe("TiDBCluster", func() { utiltc.MustWaitForComponentPhase(cli, tc, v1alpha1.PDMemberType, v1alpha1.UpgradePhase, 3*time.Minute, time.Second*10) log.Logf("PD is in UpgradePhase") + ginkgo.By("Wait for TiKV to be in UpgradePhase") + utiltc.MustWaitForComponentPhase(cli, tc, v1alpha1.TiKVMemberType, v1alpha1.UpgradePhase, 3*time.Minute, time.Second*10) + log.Logf("TiKV is in UpgradePhase") + + ginkgo.By("Wait for TiDB to be in UpgradePhase") + utiltc.MustWaitForComponentPhase(cli, tc, v1alpha1.TiDBMemberType, v1alpha1.UpgradePhase, 3*time.Minute, time.Second*10) + log.Logf("TiDB is in UpgradePhase") + + // the tc ready condition between components upgrade phase may not be observed + // and it may only observed the last ready after all components upgraded ginkgo.By("Wait for tc ready") err = oa.WaitForTidbClusterReady(tc, 10*time.Minute, 10*time.Second) framework.ExpectNoError(err, "failed to wait for TidbCluster %s/%s components ready", ns, tc.Name) @@ -2037,14 +2047,6 @@ var _ = ginkgo.Describe("TiDBCluster", func() { log.Logf("PD config:\n%s", pdCm.Data["config-file"]) gomega.Expect(pdCm.Data["config-file"]).To(gomega.ContainSubstring("lease = 3")) - ginkgo.By("Wait for TiKV to be in UpgradePhase") - utiltc.MustWaitForComponentPhase(cli, tc, v1alpha1.TiKVMemberType, v1alpha1.UpgradePhase, 3*time.Minute, time.Second*10) - log.Logf("TiKV is in UpgradePhase") - - ginkgo.By("Wait for tc ready") - err = oa.WaitForTidbClusterReady(tc, 10*time.Minute, 10*time.Second) - framework.ExpectNoError(err, "failed to wait for TidbCluster %s/%s components ready", ns, tc.Name) - ginkgo.By("Check TiKV configuration") tikvMemberName := controller.TiKVMemberName(tc.Name) tikvSts, err := stsGetter.StatefulSets(ns).Get(context.TODO(), tikvMemberName, metav1.GetOptions{}) @@ -2057,14 +2059,6 @@ var _ = ginkgo.Describe("TiDBCluster", func() { log.Logf("TiKV config:\n%s", tikvCm.Data["config-file"]) gomega.Expect(tikvCm.Data["config-file"]).To(gomega.ContainSubstring("status-thread-pool-size = 1")) - ginkgo.By("Wait for TiDB to be in UpgradePhase") - utiltc.MustWaitForComponentPhase(cli, tc, v1alpha1.TiDBMemberType, v1alpha1.UpgradePhase, 3*time.Minute, time.Second*10) - log.Logf("TiDB is in UpgradePhase") - - ginkgo.By("Wait for tc ready") - err = oa.WaitForTidbClusterReady(tc, 10*time.Minute, 10*time.Second) - framework.ExpectNoError(err, "failed to wait for TidbCluster %s/%s components ready", ns, tc.Name) - ginkgo.By("Check TiDB configuration") tidbMemberName := controller.TiDBMemberName(tc.Name) tidbSts, err := stsGetter.StatefulSets(ns).Get(context.TODO(), tidbMemberName, metav1.GetOptions{}) diff --git a/tests/e2e/util/image/image.go b/tests/e2e/util/image/image.go index 679e849a9d..98cac24955 100644 --- a/tests/e2e/util/image/image.go +++ b/tests/e2e/util/image/image.go @@ -34,7 +34,7 @@ var ( const ( // TiDB Version TiDBLatestPrev = "v7.5.3" - TiDBLatest = "v8.1.1" + TiDBLatest = "v8.1.0" // different version with PDMSImage TiDBNightlyVersion = "nightly" // specific version TiDBV7x5x0 = "v7.5.0"