ERROR: could not receive file "base/pgsql_job_cache/job_106149445683... on JOIN
- Dominant language
- C
- Stars
- 12.8k
- Forks
- 794
- Avg merge
- 2d 14h
- Merged PRs (30d)
- 31
Description
i don't how to use repartition joins, is it a bug?
```
test=# create table persons(id int ,name text);
CREATE TABLE
test=# select create_distributed_table('persons','id');
create_distributed_table
--------------------------
(1 row)
test=# create table orders(id int,No int,id_p int);
CREATE TABLE
test=# select create_distributed_table('orders','id');
create_distributed_table
--------------------------
(1 row)
test=# select * from persons a ,orders b where a.id=b.id_p;
ERROR: the query contains a join that requires repartitioning
HINT: Set citus.enable_repartition_joins to on to enable repartitioning
test=# set citus.enable_repartition_joins=on;
SET
test=# select * from persons a ,orders b where a.id=b.id_p;
ERROR: could not receive file "base/pgsql_job_cache/job_106149445649/task_000004/p_00001" from worker2:5432
test=# explain select * from persons a inner join orders b on a.id=b.id_p;
QUERY PLAN
----------------------------------------------------------------
Custom Scan (Citus Adaptive) (cost=0.00..0.00 rows=0 width=0)
Task Count: 8
Tasks Shown: None, not supported for re-partition queries
-> MapMergeJob
Map Task Count: 32
Merge Task Count: 8
-> MapMergeJob
Map Task Count: 32
Merge Task Count: 8
(9 rows)
```
```
test=# select version();
version
---------------------------------------------------------------------------------------
------------------
PostgreSQL 12.2 on x86_64-pc-linux-gnu, compiled by gcc (GCC) 4.8.5 20150623 (Red Hat
4.8.5-39), 64-bit
(1 row)
test=# select citus_version();
citus_version
---------------------------------------------------------------------------------------
-------------------
Citus 9.2.2 on x86_64-unknown-linux-gnu, compiled by gcc (GCC) 4.8.5 20150623 (Red Hat
4.8.5-39), 64-bit
(1 row)
```
Contributor guide
Assessment
This issue has not been assessed yet.