Maksim Myskov created IGNITE-22595:
--------------------------------------

             Summary: Inserting data in a multinode cluster fails if using aimem
                 Key: IGNITE-22595
                 URL: https://issues.apache.org/jira/browse/IGNITE-22595
             Project: Ignite
          Issue Type: Bug
            Reporter: Maksim Myskov


I have issues with the following scenario: insert a certain number of rows in a 
multi-node cluster.

Code for reproducing:
{code:java}
public class MultinodeInsertTest extends ClusterPerClassIntegrationTest {
    @Override
    protected int initialNodes() {
        return 2;
    }

    @Test
    public void test() throws Exception {
        sql("CREATE ZONE IF NOT EXISTS zone_test WITH 
storage_profiles='default_aimem'");
        sql("CREATE TABLE IF NOT EXISTS db1 (id int, f_name varchar, l_name 
varchar, str varchar,"
                + " PRIMARY KEY (id)) WITH PRIMARY_ZONE='ZONE_TEST';");

        int numberOfRecords = 50;

        for(int i = 0; i < numberOfRecords; i++) {
            sql(format("INSERT INTO db1 (id, f_name, l_name, str) VALUES ({}, 
'John', 'Doe', 'test');", i));
        }
    }
} {code}
There are the following errors:

 
{code:java}
[2024-06-26T22:31:23,891][ERROR][%mit_n_0%JRaft-AppendEntries-Processor-1][AbstractClientService]
 Fail to run RpcResponseClosure, the request is AppendEntriesRequestImpl 
[committedIndex=464, 
data=org.apache.ignite.raft.jraft.util.ByteString@7a99006f, 
entriesList=ArrayList [EntryMetaImpl [checksum=0, dataLen=21, 
hasChecksum=false, learnersList=null, oldLearnersList=null, oldPeersList=null, 
peersList=null, term=1, type=ENTRY_TYPE_DATA]], groupId=metastorage_group, 
peerId=mit_n_2, prevLogIndex=467, prevLogTerm=1, serverId=mit_n_0, term=1, 
timestampLong=112684583078330369].
 java.lang.IllegalArgumentException: null
        at 
org.apache.ignite.raft.jraft.util.Requires.requireTrue(Requires.java:64) 
~[ignite-raft-9.0.127-SNAPSHOT.jar:?]
        at 
org.apache.ignite.raft.jraft.core.Replicator.fillCommonFields(Replicator.java:1553)
 ~[ignite-raft-9.0.127-SNAPSHOT.jar:?]
        at 
org.apache.ignite.raft.jraft.core.Replicator.sendEntries(Replicator.java:1631) 
~[ignite-raft-9.0.127-SNAPSHOT.jar:?]
        at 
org.apache.ignite.raft.jraft.core.Replicator.sendEntries(Replicator.java:1601) 
~[ignite-raft-9.0.127-SNAPSHOT.jar:?]
        at 
org.apache.ignite.raft.jraft.core.Replicator.onRpcReturned(Replicator.java:1370)
 ~[ignite-raft-9.0.127-SNAPSHOT.jar:?]
        at 
org.apache.ignite.raft.jraft.core.Replicator$4.run(Replicator.java:1709) 
~[ignite-raft-9.0.127-SNAPSHOT.jar:?] {code}
{code:java}
[2024-06-26T22:31:26,685][WARN 
][%mit_n_0%JRaft-AppendEntries-Processor-0][FSMCallerImpl] FSMCaller already in 
error status, ignore new error
 org.apache.ignite.raft.jraft.error.RaftException: ERROR_TYPE_LOG
        at 
org.apache.ignite.raft.jraft.storage.impl.LogManagerImpl.reportError(LogManagerImpl.java:593)
 ~[ignite-raft-9.0.127-SNAPSHOT.jar:?]
        at 
org.apache.ignite.raft.jraft.storage.impl.LogManagerImpl.getEntry(LogManagerImpl.java:796)
 ~[ignite-raft-9.0.127-SNAPSHOT.jar:?]
        at 
org.apache.ignite.raft.jraft.core.Replicator.prepareEntry(Replicator.java:820) 
~[ignite-raft-9.0.127-SNAPSHOT.jar:?]
        at 
org.apache.ignite.raft.jraft.core.Replicator.sendEntries(Replicator.java:1645) 
~[ignite-raft-9.0.127-SNAPSHOT.jar:?]
        at 
org.apache.ignite.raft.jraft.core.Replicator.sendEntries(Replicator.java:1601) 
~[ignite-raft-9.0.127-SNAPSHOT.jar:?]
        at 
org.apache.ignite.raft.jraft.core.Replicator.onRpcReturned(Replicator.java:1370)
 ~[ignite-raft-9.0.127-SNAPSHOT.jar:?]
        at 
org.apache.ignite.raft.jraft.core.Replicator$4.run(Replicator.java:1709) 
~[ignite-raft-9.0.127-SNAPSHOT.jar:?] {code}
{code:java}
[2024-06-26T22:31:36,803][ERROR][%mit_n_0%Raft-Group-Client-5][ClusterTimeImpl] 
Unable to perform idle time sync
 java.util.concurrent.CompletionException: java.util.concurrent.TimeoutException
        at 
java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:331)
 ~[?:?]
        at 
java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:346)
 ~[?:?]
        at 
java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:632)
 ~[?:?] {code}



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

Reply via email to