citusdata / citusdata/citus

ERROR: could not receive file "base/pgsql_job_cache/job_106149445683... on JOIN

Open
#3,612 6 comments 0 reactions 0 assignees View on GitHub
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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.