some parts of create_distributed_table_concurrently ignores max_adaptive_executor_pool_size
- Dominant language
- C
- Stars
- 12.8k
- Forks
- 794
- Avg merge
- 2d 14h
- Merged PRs (30d)
- 31
Description
```SQL
drop table if exists ref;
create table ref (id int primary key);
select create_reference_table('ref');
insert into ref select s from generate_series(0,9) s;
drop table if exists test_1, test_2, test;
create table test (x int, y int references ref (id), t timestamptz default now()) partition by range (t);
create table test_1 partition of test for values from ('2022-01-01') to ('2022-12-31');
create table test_2 partition of test for values from ('2023-01-01') to ('2023-12-31');
insert into test (x,y) select s,s%10 from generate_series(1,100) s;
set citus.log_remote_commands to on;
SET citus.max_adaptive_executor_pool_size TO 1;
select create_distributed_table_concurrently('test','x');
```
And, concurrently check
```SQL
select * from citus_remote_connection_stats();
┌───────────┬──────┬───────────────┬──────────────────────────┐
│ hostname │ port │ database_name │ connection_count_to_node │
├───────────┼──────┼───────────────┼──────────────────────────┤
│ localhost │ 9706 │ postgres │ 12 │
│ localhost │ 9701 │ postgres │ 11 │
│ localhost │ 9703 │ postgres │ 13 │
│ localhost │ 9705 │ postgres │ 9 │
│ localhost │ 9702 │ postgres │ 14 │
│ localhost │ 9700 │ postgres │ 16 │
│ localhost │ 5432 │ postgres │ 4 │
│ localhost │ 9704 │ postgres │ 14 │
└───────────┴──────┴───────────────┴──────────────────────────┘
(8 rows)
```
It is probably we cannot pass executor pool size to `worker_split_copy `
Contributor guide
Assessment
This issue has not been assessed yet.