[
https://issues.apache.org/jira/browse/IGNITE-28925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18100078#comment-18100078
]
Ignite TC Bot commented on IGNITE-28925:
----------------------------------------
{panel:title=Branch: [pull/13407/head] Base: [master] : No blockers
found!|borderStyle=dashed|borderColor=#ccc|titleBGColor=#D6F7C1}{panel}
{panel:title=Branch: [pull/13407/head] Base: [master] : New Tests
(4)|borderStyle=dashed|borderColor=#ccc|titleBGColor=#D6F7C1}
{color:#00008b}Calcite SQL 3{color} [[tests
4|https://ci2.ignite.apache.org/viewLog.html?buildId=9237217]]
* {color:#013220}IgniteCalciteTestSuite3:
SortAggregateIntegrationTest.testRequestRowsAfterInputEnds[sqlTxMode=ALL] -
PASSED{color}
* {color:#013220}IgniteCalciteTestSuite3:
SortAggregateIntegrationTest.testRequestRowsAfterInputEnds[sqlTxMode=RANDOM] -
PASSED{color}
* {color:#013220}IgniteCalciteTestSuite3:
SortAggregateIntegrationTest.testRequestRowsAfterInputEnds[sqlTxMode=NONE] -
PASSED{color}
* {color:#013220}IgniteCalciteTestSuite3:
CollectIntegrationTest.testRequestLimitedRowsCountFromCollect - PASSED{color}
{panel}
[TeamCity *--> Run :: All*
Results|https://ci2.ignite.apache.org/viewLog.html?buildId=9235087&buildTypeId=IgniteTests24Java8_RunAll]
{color:#ffffff}tcbot-analysis-comment chainBuildId=9235087
rerunBuildIds=9237211,9237213,9237215,9237217,9237219,9237221,9237223{color}
> Calcite engine. SortAggregateNode can call downstream().end() twice
> -------------------------------------------------------------------
>
> Key: IGNITE-28925
> URL: https://issues.apache.org/jira/browse/IGNITE-28925
> Project: Ignite
> Issue Type: Bug
> Reporter: Aleksey Plekhanov
> Assignee: Aleksey Plekhanov
> Priority: Major
> Labels: ise
> Time Spent: 10m
> Remaining Estimate: 0h
>
> Requested rows count is not reset on downstream end, this can lead to
> assertions when invariant "not waiting rows, but got rows or end event" is
> violated.
> For example:
> {code:java}
> sql("CREATE TABLE t(a INTEGER PRIMARY KEY, b INTEGER) WITH
> template=replicated," + atomicity());
> for (int i = 0; i < 512; i++)
> sql("INSERT INTO t VALUES (?, ?)", i, i);
> assertQuery("SELECT t1.a FROM t AS t1 JOIN (SELECT a, count(a) FROM t GROUP
> BY a) AS t2 ON t1.a = t2.a")
> .resultSize(512)
> .check(); {code}
> Fails with:
> {noformat}
> Caused by: java.lang.AssertionError
> at
> org.apache.ignite.internal.processors.query.calcite.exec.rel.MergeJoinNode.endRight(MergeJoinNode.java:216)
> at
> org.apache.ignite.internal.processors.query.calcite.exec.rel.MergeJoinNode$2.end(MergeJoinNode.java:165)
> at
> org.apache.ignite.internal.processors.query.calcite.exec.rel.SortAggregateNode.end(SortAggregateNode.java:167)
> at
> org.apache.ignite.internal.processors.query.calcite.exec.rel.ScanNode.processNextBatch(ScanNode.java:203)
> at
> org.apache.ignite.internal.processors.query.calcite.exec.rel.ScanStorageNode.processNextBatch(ScanStorageNode.java:70)
> at
> org.apache.ignite.internal.processors.query.calcite.exec.rel.ScanNode.push(ScanNode.java:142)
> {noformat}
> First time MergeJoinNode is ended on {{SortAggregateNode.end ->
> SortAggregateNode.doPush -> MergeJoinNode.pushRight -> MergeJoinNode.join ->
> MergeJoinNode.tryToRequestInputs -> SortAggregateNode.request}}
> Second time MergeJoinNode is ended in the same {{SortAggregateNode.end}} call
> after {{SortAggregateNode.doPush}}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
