Skip to content

Commit

Permalink
fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
xiongjiwei committed Nov 25, 2022
1 parent e2a08d4 commit acd67cd
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions executor/set_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -863,13 +863,13 @@ func TestSetVar(t *testing.T) {
tk.MustQuery("SELECT @@GLOBAL.validate_password.length").Check(testkit.Rows("6"))

// test tidb_cdc_write_source
require.Equal(t, 0, tk.Session().GetSessionVars().CDCWriteSource)
require.Equal(t, uint64(0), tk.Session().GetSessionVars().CDCWriteSource)
tk.MustQuery("select @@tidb_cdc_write_source").Check(testkit.Rows("0"))
tk.MustExec("set @@session.tidb_cdc_write_source = 2")
tk.MustQuery("select @@tidb_cdc_write_source").Check(testkit.Rows("2"))
require.Equal(t, 2, tk.Session().GetSessionVars().CDCWriteSource)
require.Equal(t, uint64(2), tk.Session().GetSessionVars().CDCWriteSource)
tk.MustExec("set @@session.tidb_cdc_write_source = 0")
require.Equal(t, 0, tk.Session().GetSessionVars().CDCWriteSource)
require.Equal(t, uint64(0), tk.Session().GetSessionVars().CDCWriteSource)
}

func TestGetSetNoopVars(t *testing.T) {
Expand Down

0 comments on commit acd67cd

Please sign in to comment.