This is an automated email from the ASF dual-hosted git repository.

rpuch pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 0d18b04561c IGNITE-24687 Use integration test defaults for schema sync 
settings in colocation tests (#5331)
0d18b04561c is described below

commit 0d18b04561c288e14fce44233469446cb6b182e0
Author: Roman Puchkovskiy <roman.puchkovs...@gmail.com>
AuthorDate: Mon Mar 3 15:19:03 2025 +0400

    IGNITE-24687 Use integration test defaults for schema sync settings in 
colocation tests (#5331)
---
 .../internal/partition/replicator/AbstractZoneReplicationTest.java | 2 +-
 .../internal/partition/replicator/ItAbstractColocationTest.java    | 2 +-
 .../apache/ignite/internal/partition/replicator/fixtures/Node.java | 7 ++++++-
 3 files changed, 8 insertions(+), 3 deletions(-)

diff --git 
a/modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/AbstractZoneReplicationTest.java
 
b/modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/AbstractZoneReplicationTest.java
index 1e7b3ca5529..8a1e7edf1ed 100644
--- 
a/modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/AbstractZoneReplicationTest.java
+++ 
b/modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/AbstractZoneReplicationTest.java
@@ -95,7 +95,7 @@ abstract class AbstractZoneReplicationTest extends 
IgniteAbstractTest {
     @InjectConfiguration
     private static ReplicationConfiguration replicationConfiguration;
 
-    @InjectConfiguration
+    @InjectConfiguration("mock.idleSyncTimeInterval = " + 
Node.METASTORAGE_IDLE_SYNC_TIME_INTERVAL_MS)
     private static MetaStorageConfiguration metaStorageConfiguration;
 
     @InjectConfiguration("mock.profiles = {" + DEFAULT_STORAGE_PROFILE + 
".engine = aipersist, test.engine=test}")
diff --git 
a/modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItAbstractColocationTest.java
 
b/modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItAbstractColocationTest.java
index 1c126996cac..ffbcbc0add7 100644
--- 
a/modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItAbstractColocationTest.java
+++ 
b/modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItAbstractColocationTest.java
@@ -102,7 +102,7 @@ abstract class ItAbstractColocationTest extends 
IgniteAbstractTest {
     @InjectConfiguration("mock.profiles = {" + DEFAULT_STORAGE_PROFILE + 
".engine = aipersist, test.engine=test}")
     private StorageConfiguration storageConfiguration;
 
-    @InjectConfiguration
+    @InjectConfiguration("mock.idleSyncTimeInterval = " + 
Node.METASTORAGE_IDLE_SYNC_TIME_INTERVAL_MS)
     private MetaStorageConfiguration metaStorageConfiguration;
 
     @InjectConfiguration
diff --git 
a/modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/fixtures/Node.java
 
b/modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/fixtures/Node.java
index c0ec396b245..b3232715e47 100644
--- 
a/modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/fixtures/Node.java
+++ 
b/modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/fixtures/Node.java
@@ -193,6 +193,11 @@ import org.junit.jupiter.api.TestInfo;
 public class Node {
     private static final IgniteLogger LOG = Loggers.forClass(Node.class);
 
+    private static final int DELAY_DURATION_MS = 100;
+
+    /** The interval between two consecutive MS idle safe time syncs. */
+    public static final int METASTORAGE_IDLE_SYNC_TIME_INTERVAL_MS = 
DELAY_DURATION_MS / 2;
+
     public final String name;
 
     private final Loza raftManager;
@@ -590,7 +595,7 @@ public class Node {
                         .thenApply(Entry::value)
         );
 
-        LongSupplier delayDurationMsSupplier = () -> 10L;
+        LongSupplier delayDurationMsSupplier = () -> DELAY_DURATION_MS;
 
         catalogManager = new CatalogManagerImpl(
                 new UpdateLogImpl(metaStorageManager),

Reply via email to