You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Andrey Mashenkov (Jira)" <ji...@apache.org> on 2023/03/28 15:52:00 UTC

[jira] [Assigned] (IGNITE-19018) Sql. Investigate AssertionError in ScanNode. ItCorrelatesTest fails when distribution of VALUES is changed from Broadcast to Single.

     [ https://issues.apache.org/jira/browse/IGNITE-19018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Andrey Mashenkov reassigned IGNITE-19018:
-----------------------------------------

    Assignee: Andrey Mashenkov

> 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
>            Assignee: Andrey Mashenkov
>            Priority: Critical
>              Labels: calcite3-required, ignite-3
>
> The query in ItCorrelatesTest triggers AssertionError in ScanNode. This behaviour is observed in after modification operations were changed in https://issues.apache.org/jira/browse/IGNITE-18225 is implemented. 
> {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)