[jira] [Created] (IGNITE-23072) Sql. NoSuchElementException: null / NPE in AsyncRootNode.flush

[Maksim Zhuravkov (Jira)]

Maksim Zhuravkov created IGNITE-23072:
-----------------------------------------

             Summary: Sql. NoSuchElementException: null / NPE in 
AsyncRootNode.flush
                 Key: IGNITE-23072
                 URL: https://issues.apache.org/jira/browse/IGNITE-23072
             Project: Ignite
          Issue Type: Bug
          Components: sql
            Reporter: Maksim Zhuravkov


Reproducer

{code:java}
@State(Scope.Benchmark)
@Fork(1)
@Threads(1)
@Warmup(iterations = 10, time = 2)
@Measurement(iterations = 20, time = 2)
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MILLISECONDS)
@SuppressWarnings({"WeakerAccess", "unused"})
public class SqlCountBenchmark extends AbstractMultiNodeBenchmark {

    private IgniteSql sql;

    @Param({"1", "2", "3", "4", "5"})
    private int clusterSize;

    @Param({"5", "10", "15", "20"})
    private int partitionsCount;

    /** Fills the table with data. */
    @Setup
    public void setUp() throws IOException {
        populateTable(TABLE_NAME, 30_000, 1_000);

        sql = publicIgnite.sql();
    }

    @Override
    protected int partitionCount() {
        return partitionsCount;
    }
    
    @Benchmark
    public void select1(Blackhole bh) {
        try (var rs = sql.execute(null, "SELECT 1 FROM usertable")) {
            bh.consume(rs.next());
        }
    }

    /**
     * Benchmark's entry point.
     */
    public static void main(String[] args) throws RunnerException {
        Options opt = new OptionsBuilder()
                .include(".*" + SqlCountBenchmark.class.getSimpleName() + 
".select1")
                .build();

        new Runner(opt).run();
    }

    @Override
    protected int nodes() {
        return clusterSize;
    }
}

{code}


{noformat}
java.lang.NullPointerException: null
        at 
org.apache.ignite.internal.sql.engine.exec.rel.AsyncRootNode.flush(AsyncRootNode.java:228)
 ~[main/:?]
        at 
org.apache.ignite.internal.sql.engine.exec.rel.AsyncRootNode.push(AsyncRootNode.java:92)
 ~[main/:?]
        at 
org.apache.ignite.internal.sql.engine.exec.rel.Inbox.pushUnordered(Inbox.java:314)
 ~[main/:?]
        at 
org.apache.ignite.internal.sql.engine.exec.rel.Inbox.push(Inbox.java:202) 
~[main/:?]
        at 
org.apache.ignite.internal.sql.engine.exec.rel.Inbox.onBatchReceived(Inbox.java:180)
 ~[main/:?]
        at 
org.apache.ignite.internal.sql.engine.exec.ExchangeServiceImpl.onMessage(ExchangeServiceImpl.java:173)
 ~[main/:?]
        at 
org.apache.ignite.internal.sql.engine.exec.ExchangeServiceImpl.lambda$start$1(ExchangeServiceImpl.java:78)
 ~[main/:?]
        at 
org.apache.ignite.internal.sql.engine.message.MessageServiceImpl.onMessageInternal(MessageServiceImpl.java:151)
 ~[main/:?]
        at 
org.apache.ignite.internal.sql.engine.message.MessageServiceImpl.lambda$onMessage$0(MessageServiceImpl.java:115)
 ~[main/:?]
        at 
org.apache.ignite.internal.sql.engine.exec.QueryTaskExecutorImpl.lambda$execute$0(QueryTaskExecutorImpl.java:83)
 ~[main/:?]
        at 
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
 [?:?]
        at 
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
 [?:?]
        at java.base/java.lang.Thread.run(Thread.java:829) [?:?]
{noformat}


On a 3 node cluster


{noformat}
java.util.NoSuchElementException: null
        at java.base/java.util.AbstractQueue.remove(AbstractQueue.java:117) 
~[?:?]
        at 
org.apache.ignite.internal.sql.engine.exec.rel.AsyncRootNode.flush(AsyncRootNode.java:235)
 ~[ignite-sql-engine-3.0.0-SNAPSHOT.jar:?]
        at 
org.apache.ignite.internal.sql.engine.exec.rel.AsyncRootNode.push(AsyncRootNode.java:92)
 ~[ignite-sql-engine-3.0.0-SNAPSHOT.jar:?]
        at 
org.apache.ignite.internal.sql.engine.exec.rel.Inbox.pushUnordered(Inbox.java:314)
 ~[ignite-sql-engine-3.0.0-SNAPSHOT.jar:?]
        at 
org.apache.ignite.internal.sql.engine.exec.rel.Inbox.push(Inbox.java:202) 
~[ignite-sql-engine-3.0.0-SNAPSHOT.jar:?]
        at 
org.apache.ignite.internal.sql.engine.exec.rel.Inbox.onBatchReceived(Inbox.java:180)
 ~[ignite-sql-engine-3.0.0-SNAPSHOT.jar:?]
        at 
org.apache.ignite.internal.sql.engine.exec.ExchangeServiceImpl.onMessage(ExchangeServiceImpl.java:173)
 ~[ignite-sql-engine-3.0.0-SNAPSHOT.jar:?]
        at 
org.apache.ignite.internal.sql.engine.exec.ExchangeServiceImpl.lambda$start$1(ExchangeServiceImpl.java:78)
 ~[ignite-sql-engine-3.0.0-SNAPSHOT.jar:?]
        at 
org.apache.ignite.internal.sql.engine.message.MessageServiceImpl.onMessageInternal(MessageServiceImpl.java:151)
 ~[ignite-sql-engine-3.0.0-SNAPSHOT.jar:?]
        at 
org.apache.ignite.internal.sql.engine.message.MessageServiceImpl.lambda$onMessage$0(MessageServiceImpl.java:115)
 ~[ignite-sql-engine-3.0.0-SNAPSHOT.jar:?]
        at 
org.apache.ignite.internal.sql.engine.exec.QueryTaskExecutorImpl.lambda$execute$0(QueryTaskExecutorImpl.java:83)
 ~[ignite-sql-engine-3.0.0-SNAPSHOT.jar:?]
{noformat}




--
This message was sent by Atlassian Jira
(v8.20.10#820010)