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),