(ignite-extensions) branch master updated: IGNITE-28858 Reduce CDC replication tests execution time (#359)

[av]

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

anton-vinogradov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git


The following commit(s) were added to refs/heads/master by this push:
     new 9ff3c921 IGNITE-28858 Reduce CDC replication tests execution time 
(#359)
9ff3c921 is described below

commit 9ff3c9216e2a2d55221ec7a18fd4b8efed5fa57d
Author: Anton Vinogradov <a...@apache.org>
AuthorDate: Mon Jul 6 21:03:28 2026 +0300

    IGNITE-28858 Reduce CDC replication tests execution time (#359)
---
 .../src/test/java/org/apache/ignite/cdc/AbstractReplicationTest.java  | 4 ++--
 .../apache/ignite/cdc/postgresql/CdcPostgreSqlReplicationTest.java    | 2 +-
 .../org/apache/ignite/cdc/postgresql/JavaToSqlTypeMapperTest.java     | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/AbstractReplicationTest.java
 
b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/AbstractReplicationTest.java
index ee75f0c7..f10a70c6 100644
--- 
a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/AbstractReplicationTest.java
+++ 
b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/AbstractReplicationTest.java
@@ -203,7 +203,7 @@ public abstract class AbstractReplicationTest extends 
GridCommonAbstractTest {
                     .setCdcEnabled(true)));
 
             cfg.getDataStorageConfiguration()
-                .setWalForceArchiveTimeout(5_000);
+                .setWalForceArchiveTimeout(1_000);
 
             cfg.setConsistentId(igniteInstanceName);
         }
@@ -522,7 +522,7 @@ public abstract class AbstractReplicationTest extends 
GridCommonAbstractTest {
     /** Test that destination cluster applies expiration policy on received 
entries. */
     @Test
     public void testWithExpiryPolicy() throws Exception {
-        Factory<? extends ExpiryPolicy> factory = () -> new 
CreatedExpiryPolicy(new Duration(TimeUnit.SECONDS, 30));
+        Factory<? extends ExpiryPolicy> factory = () -> new 
CreatedExpiryPolicy(new Duration(TimeUnit.SECONDS, 10));
 
         IgniteCache<Integer, ConflictResolvableTestData> srcCache = 
createCache(srcCluster[0], ACTIVE_PASSIVE_CACHE, factory);
         IgniteCache<Integer, ConflictResolvableTestData> destCache = 
createCache(destCluster[0], ACTIVE_PASSIVE_CACHE, factory);
diff --git 
a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/postgresql/CdcPostgreSqlReplicationTest.java
 
b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/postgresql/CdcPostgreSqlReplicationTest.java
index 9bc93091..740fc511 100644
--- 
a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/postgresql/CdcPostgreSqlReplicationTest.java
+++ 
b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/postgresql/CdcPostgreSqlReplicationTest.java
@@ -103,7 +103,7 @@ public class CdcPostgreSqlReplicationTest extends 
CdcPostgreSqlReplicationAbstra
             .setCdcEnabled(true);
 
         DataStorageConfiguration dataStorageConfiguration = new 
DataStorageConfiguration()
-            .setWalForceArchiveTimeout(5_000)
+            .setWalForceArchiveTimeout(1_000)
             .setDefaultDataRegionConfiguration(dataRegionConfiguration);
 
         cfg.setDataStorageConfiguration(dataStorageConfiguration);
diff --git 
a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/postgresql/JavaToSqlTypeMapperTest.java
 
b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/postgresql/JavaToSqlTypeMapperTest.java
index 0435f5ac..45a7b723 100644
--- 
a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/postgresql/JavaToSqlTypeMapperTest.java
+++ 
b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/postgresql/JavaToSqlTypeMapperTest.java
@@ -92,7 +92,7 @@ public class JavaToSqlTypeMapperTest extends 
CdcPostgreSqlReplicationAbstractTes
             .setCdcEnabled(true);
 
         DataStorageConfiguration dataStorageConfiguration = new 
DataStorageConfiguration()
-            .setWalForceArchiveTimeout(5_000)
+            .setWalForceArchiveTimeout(1_000)
             .setDefaultDataRegionConfiguration(dataRegionConfiguration);
 
         cfg.setDataStorageConfiguration(dataStorageConfiguration);