diff options
Diffstat (limited to 'src/test')
| -rw-r--r-- | src/test/regress/expected/select_parallel.out | 14 | ||||
| -rw-r--r-- | src/test/regress/sql/select_parallel.sql | 8 |
2 files changed, 22 insertions, 0 deletions
diff --git a/src/test/regress/expected/select_parallel.out b/src/test/regress/expected/select_parallel.out index 2286fafab39..164c4bd61c9 100644 --- a/src/test/regress/expected/select_parallel.out +++ b/src/test/regress/expected/select_parallel.out @@ -99,7 +99,21 @@ explain (costs off) -> Index Only Scan using tenk1_unique1 on tenk1 (3 rows) +-- test the sanity of parallel query after the active role is dropped. set force_parallel_mode=1; +drop role if exists regress_parallel_worker; +NOTICE: role "regress_parallel_worker" does not exist, skipping +create role regress_parallel_worker; +set role regress_parallel_worker; +reset session authorization; +drop role regress_parallel_worker; +select count(*) from tenk1; + count +------- + 10000 +(1 row) + +reset role; explain (costs off) select stringu1::int2 from tenk1 where unique1 = 1; QUERY PLAN diff --git a/src/test/regress/sql/select_parallel.sql b/src/test/regress/sql/select_parallel.sql index 38d3166742c..e310c096811 100644 --- a/src/test/regress/sql/select_parallel.sql +++ b/src/test/regress/sql/select_parallel.sql @@ -39,7 +39,15 @@ explain (costs off) select sum(parallel_restricted(unique1)) from tenk1 group by(parallel_restricted(unique1)); +-- test the sanity of parallel query after the active role is dropped. set force_parallel_mode=1; +drop role if exists regress_parallel_worker; +create role regress_parallel_worker; +set role regress_parallel_worker; +reset session authorization; +drop role regress_parallel_worker; +select count(*) from tenk1; +reset role; explain (costs off) select stringu1::int2 from tenk1 where unique1 = 1; |