fix build

Signed-off-by: disksing <i@disksing.com>
pingcap · Jun 21, 2021 · 76d562c · 76d562c
1 parent 778e441
commit 76d562c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/cdc/model/changefeed_test.go b/cdc/model/changefeed_test.go
@@ -345,7 +345,7 @@ func (s *changefeedSuite) TestGetTs(c *check.C) {
 			CreateTime: createTime,
 		}
 	)
-	c.Assert(info.GetStartTs(), check.Equals, oracle.EncodeTSO(createTime.Unix()*1000))
+	c.Assert(info.GetStartTs(), check.Equals, oracle.GoTimeToTS(createTime))
 	info.StartTs = startTs
 	c.Assert(info.GetStartTs(), check.Equals, startTs)
 

diff --git a/cdc/puller/mock_puller_test.go b/cdc/puller/mock_puller_test.go
@@ -54,7 +54,7 @@ func (s *mockPullerSuite) TestTxnSort(c *check.C) {
 	pm.MustExec("insert into test.test(id, a) values(?, ?)", 2, 2)
 	pm.MustExec("insert into test.test(id, a) values(?, ?)", 3, 3)
 	pm.MustExec("delete from test.test")
-	waitForGrowingTs(&ts, oracle.EncodeTSO(time.Now().Unix()*1000))
+	waitForGrowingTs(&ts, oracle.GoTimeToTS(time.Now()))
 }
 
 func (s *mockPullerSuite) TestDDLPuller(c *check.C) {
@@ -93,7 +93,7 @@ func (s *mockPullerSuite) TestDDLPuller(c *check.C) {
 	pm.MustExec("insert into test.test(id, a) values(?, ?)", 2, 2)
 	pm.MustExec("insert into test.test(id, a) values(?, ?)", 3, 3)
 	pm.MustExec("delete from test.test")
-	waitForGrowingTs(&ts, oracle.EncodeTSO(time.Now().Unix()*1000))
+	waitForGrowingTs(&ts, oracle.GoTimeToTS(time.Now()))
 }
 
 func (s *mockPullerSuite) TestStartTs(c *check.C) {
@@ -122,7 +122,7 @@ func (s *mockPullerSuite) TestStartTs(c *check.C) {
 	pm.MustExec("insert into test.test(id, a) values(?, ?)", 2, 2)
 	pm.MustExec("insert into test.test(id, a) values(?, ?)", 3, 3)
 	pm.MustExec("delete from test.test")
-	waitForGrowingTs(&ts, oracle.EncodeTSO(time.Now().Unix()*1000))
+	waitForGrowingTs(&ts, oracle.GoTimeToTS(time.Now()))
 	cancel()
 	mu.Lock()
 	index := len(rawTxns) / 2