fix enabling Unified Sorter by default

pingcap · May 12, 2021 · 7f645cd · 7f645cd
1 parent 943de6b
commit 7f645cd
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/cdc/model/changefeed.go b/cdc/model/changefeed.go
@@ -188,7 +188,7 @@ func (info *ChangeFeedInfo) Clone() (*ChangeFeedInfo, error) {
 func (info *ChangeFeedInfo) VerifyAndFix() error {
 	defaultConfig := config.GetDefaultReplicaConfig()
 	if info.Engine == "" {
-		info.Engine = SortInMemory
+		info.Engine = SortUnified
 	}
 	if info.Config.Filter == nil {
 		info.Config.Filter = defaultConfig.Filter

diff --git a/cdc/model/changefeed_test.go b/cdc/model/changefeed_test.go
@@ -179,7 +179,7 @@ func (s *configSuite) TestVerifyAndFix(c *check.C) {
 
 	err := info.VerifyAndFix()
 	c.Assert(err, check.IsNil)
-	c.Assert(info.Engine, check.Equals, SortInMemory)
+	c.Assert(info.Engine, check.Equals, SortUnified)
 
 	marshalConfig1, err := info.Config.Marshal()
 	c.Assert(err, check.IsNil)