test: fix flaky test TestSyncJobSchemaVerLoop (#53507)

close #53508
pingcap · May 23, 2024 · 322f87a · 322f87a
1 parent 22dc064
commit 322f87a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/pkg/ddl/syncer/syncer.go b/pkg/ddl/syncer/syncer.go
@@ -434,6 +434,7 @@ func (s *schemaVersionSyncer) OwnerCheckAllVersions(ctx context.Context, jobID i
 			case <-notifyCh:
 				return nil
 			case <-ctx.Done():
+				item.clearMatchFn()
 				return errors.Trace(ctx.Err())
 			case <-time.After(time.Second):
 				item.clearMatchFn()

diff --git a/pkg/ddl/syncer/syncer_nokit_test.go b/pkg/ddl/syncer/syncer_nokit_test.go
@@ -188,6 +188,4 @@ func TestSyncJobSchemaVerLoop(t *testing.T) {
 
 	cancel()
 	wg.Wait()
-
-	require.Zero(t, jobNodeVersionCnt())
 }