[
https://issues.apache.org/jira/browse/IGNITE-22595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maksim Myskov updated IGNITE-22595:
-----------------------------------
Labels: ignite-3 (was: )
> 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
> Priority: Major
> Labels: ignite-3
>
> 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)
