mustafasrepo commented on issue #10421:
URL: https://github.com/apache/datafusion/issues/10421#issuecomment-2102576381

   > Thanks @fabianmurariu
   > 
   > cc @mustafasrepo in case you have any thoughts
   
   I have tried to reproduce problem by defining absolutely necessary fields in 
the query with below queries
   ```sql
   statement ok
   CREATE TABLE IF NOT EXISTS _default (name VARCHAR, src BIGINT, dst BIGINT, 
id BIGINT) AS VALUES('mustafa', 1, 2, 0),('test', 2, 3, 1);
   
   statement ok
   CREATE TABLE IF NOT EXISTS nodes (name VARCHAR,id BIGINT) AS VALUES('TR', 
1),('GR', 2);
   
   statement ok
   set datafusion.execution.target_partitions = 8;
   
   query TTT
   WITH e1 AS (SELECT * FROM _default),
     e2 AS (SELECT * FROM _default),
     a AS (SELECT * FROM nodes),
     b AS (SELECT * FROM nodes),
     c AS (SELECT * FROM nodes)
     SELECT a.name, b.name, c.name
   FROM e1 JOIN a ON e1.src = a.id JOIN b ON e1.dst = b.id JOIN e2 ON b.id = 
e2.src JOIN c ON e2.dst = c.id WHERE e1.id <> e2.id;
   ----
   ```
   However, this test seems to pass. Unfortunately I cannot debug further. 
After seeing plans, or after full reproducer I will take another look.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org
For additional commands, e-mail: github-h...@datafusion.apache.org

Reply via email to