executor, tests: move IT in executor/test/issuetest to `tests/integ…

…rationtest` (#47077)

ref #47076

executor/test/issuetest/BUILD.bazel

@@ -8,7 +8,7 @@ go_test(
         "main_test.go",
     ],
     flaky = True,
-    shard_count = 50,
+    shard_count = 17,
     deps = [
         "//autoid_service",
         "//config",
@@ -18,7 +18,6 @@ go_test(
         "//parser/charset",
         "//parser/mysql",
         "//session",
-        "//sessionctx/variable",
         "//testkit",
         "//util",
         "//util/memory",

executor/window_test.go

@@ -32,30 +32,20 @@ func TestWindowFunctions(t *testing.T) {
 		tk.MustExec("set @@tidb_enable_pipelined_window_function=1;")
 	}()
 	doTestWindowFunctions(tk)
-}
 
-func TestWindowParallelFunctions(t *testing.T) {
-	store := testkit.CreateMockStore(t)
-	tk := testkit.NewTestKit(t, store)
+	// TestWindowParallelFunctions
 	tk.MustExec("set @@tidb_window_concurrency = 4")
 	tk.MustExec("set @@tidb_enable_pipelined_window_function = 0")
-	defer func() {
-		tk.MustExec("set @@tidb_enable_pipelined_window_function=1;")
-	}()
 	doTestWindowFunctions(tk)
-}
 
-func TestPipelinedWindowFunctions(t *testing.T) {
-	store := testkit.CreateMockStore(t)
-	tk := testkit.NewTestKit(t, store)
+	// TestPipelinedWindowFunctions
 	tk.MustExec("set @@tidb_window_concurrency = 1")
+	tk.MustExec("set @@tidb_enable_pipelined_window_function = 1")
 	doTestWindowFunctions(tk)
-}
 
-func TestPipelinedWindowParallelFunctions(t *testing.T) {
-	store := testkit.CreateMockStore(t)
-	tk := testkit.NewTestKit(t, store)
+	// TestPipelinedWindowParallelFunctions
 	tk.MustExec("set @@tidb_window_concurrency = 4")
+	tk.MustExec("set @@tidb_enable_pipelined_window_function = 1")
 	doTestWindowFunctions(tk)
 }
 
@@ -194,6 +184,7 @@ func doTestWindowFunctions(tk *testkit.TestKit) {
 
 	tk.MustQuery("select lead(a) over(partition by null) from t").Sort().Check(testkit.Rows("1", "2", "2", "<nil>"))
 
+	tk.MustExec("drop table if exists issue10494")
 	tk.MustExec("create table issue10494(a INT, b CHAR(1), c DATETIME, d BLOB)")
 	tk.MustExec("insert into issue10494 VALUES (1,'x','2010-01-01','blob'), (2, 'y', '2011-01-01', ''), (3, 'y', '2012-01-01', ''), (4, 't', '2012-01-01', 'blob'), (5, null, '2013-01-01', null)")
 	tk.MustQuery("SELECT a, b, c, SUM(a) OVER (RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW) FROM issue10494 order by a;").Check(
@@ -206,6 +197,7 @@ func doTestWindowFunctions(tk *testkit.TestKit) {
 		),
 	)
 
+	tk.MustExec("drop table if exists td_dec")
 	tk.MustExec("CREATE TABLE td_dec (id DECIMAL(10,2), sex CHAR(1));")
 	tk.MustExec("insert into td_dec value (2.0, 'F'), (NULL, 'F'), (1.0, 'F')")
 	tk.MustQuery("SELECT id, FIRST_VALUE(id) OVER w FROM td_dec WINDOW w AS (ORDER BY id);").Check(

store/mockstore/mockcopr/BUILD.bazel

@@ -55,7 +55,6 @@ go_test(
     ],
     embed = [":mockcopr"],
     flaky = True,
-    shard_count = 3,
     deps = [
         "//domain",
         "//kv",

store/mockstore/mockcopr/executor_test.go

@@ -109,22 +109,6 @@ func TestResolvedLargeTxnLocks(t *testing.T) {
 	require.True(t, ok)
 }
 
-func TestIssue15662(t *testing.T) {
-	store := testkit.CreateMockStore(t)
-	tk := testkit.NewTestKit(t, store)
-
-	tk.MustExec("use test")
-
-	tk.MustExec("create table V (id int primary key, col_int int)")
-	tk.MustExec("insert into V values (1, 8)")
-
-	tk.MustExec("create table F (id int primary key, col_int int)")
-	tk.MustExec("insert into F values (1, 8)")
-
-	tk.MustQuery("select table1.`col_int` as field1, table1.`col_int` as field2 from V as table1 left join F as table2 on table1.`col_int` = table2.`col_int` order by field1, field2 desc limit 2").
-		Check(testkit.Rows("8 8"))
-}
-
 func putMutations(kvpairs ...string) []*kvrpcpb.Mutation {
 	var mutations []*kvrpcpb.Mutation
 	for i := 0; i < len(kvpairs); i += 2 {