Maksim Zhuravkov created IGNITE-19018: -----------------------------------------
Summary: Sql. Investigate AssertionError in ScanNode. ItCorrelatesTest fails when distribution of VALUES is changed from Broadcast to Single. Key: IGNITE-19018 URL: https://issues.apache.org/jira/browse/IGNITE-19018 Project: Ignite Issue Type: Bug Components: sql Affects Versions: 3.0.0-beta2 Reporter: Maksim Zhuravkov The query in ItCorrelatesTest triggers AssertionError in ScanNode. {code:java} assertQuery("SELECT * FROM test1 WHERE " + "EXISTS(SELECT * FROM test2 WHERE (SELECT test1.a)=test2.a AND (SELECT test1.b)<>test2.c) " + "AND NOT EXISTS(SELECT * FROM test2 WHERE (SELECT test1.a)=test2.a AND (SELECT test1.b)<test2.c)") .returns(12, 2) .check(); {code} AssertionError: {code:java} Caused by: java.lang.AssertionError: rowsCnt=512, requested=512 at org.apache.ignite.internal.sql.engine.exec.rel.ScanNode.request(ScanNode.java:53) at org.apache.ignite.internal.sql.engine.exec.rel.ProjectNode.request(ProjectNode.java:59) at org.apache.ignite.internal.sql.engine.exec.rel.HashAggregateNode.request(HashAggregateNode.java:110) at org.apache.ignite.internal.sql.engine.exec.rel.Outbox.flush(Outbox.java:267) at org.apache.ignite.internal.sql.engine.exec.rel.Outbox.onRequest(Outbox.java:108) at org.apache.ignite.internal.sql.engine.exec.ExchangeServiceImpl.lambda$onMessage$3(ExchangeServiceImpl.java:178) at org.apache.ignite.internal.sql.engine.exec.ExchangeServiceImpl.onMessage(ExchangeServiceImpl.java:187) at org.apache.ignite.internal.sql.engine.exec.ExchangeServiceImpl.lambda$start$1(ExchangeServiceImpl.java:73) at org.apache.ignite.internal.sql.engine.message.MessageServiceImpl.onMessageInternal(MessageServiceImpl.java:164) at org. {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)