You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ni...@apache.org on 2022/12/05 12:23:00 UTC
[ignite-extensions] branch master updated: IGNITE-18333 Fix testCdcStopOnClientNodeCrash (#197)
This is an automated email from the ASF dual-hosted git repository.
nizhikov 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 96ed062b IGNITE-18333 Fix testCdcStopOnClientNodeCrash (#197)
96ed062b is described below
commit 96ed062b5c53079f3c0bf01902f9232ec44e0181
Author: Nikolay <ni...@apache.org>
AuthorDate: Mon Dec 5 15:22:54 2022 +0300
IGNITE-18333 Fix testCdcStopOnClientNodeCrash (#197)
---
.../apache/ignite/cdc/CdcIgniteToIgniteReplicationTest.java | 10 +++++++---
1 file changed, 7 insertions(+), 3 deletions(-)
diff --git a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/CdcIgniteToIgniteReplicationTest.java b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/CdcIgniteToIgniteReplicationTest.java
index 5e701882..d1d9e60d 100644
--- a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/CdcIgniteToIgniteReplicationTest.java
+++ b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/CdcIgniteToIgniteReplicationTest.java
@@ -25,6 +25,7 @@ import org.apache.ignite.Ignition;
import org.apache.ignite.cdc.thin.IgniteToIgniteClientCdcStreamer;
import org.apache.ignite.configuration.ClientConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
+import org.apache.ignite.failure.StopNodeOrHaltFailureHandler;
import org.apache.ignite.internal.IgniteEx;
import org.apache.ignite.internal.IgniteInternalFuture;
import org.apache.ignite.internal.cdc.CdcMain;
@@ -92,8 +93,11 @@ public class CdcIgniteToIgniteReplicationTest extends AbstractReplicationTest {
.setDestinationClientConfiguration(new ClientConfiguration()
.setAddresses(hostAddresses(dest)));
}
- else
- streamer = new IgniteToIgniteCdcStreamer().setDestinationIgniteConfiguration(destCfg);
+ else {
+ streamer = new IgniteToIgniteCdcStreamer().setDestinationIgniteConfiguration(
+ new IgniteConfiguration(destCfg).setFailureHandler(new StopNodeOrHaltFailureHandler(true, 30_000))
+ );
+ }
streamer.setMaxBatchSize(KEYS_CNT);
streamer.setCaches(Collections.singleton(cache));
@@ -146,7 +150,7 @@ public class CdcIgniteToIgniteReplicationTest extends AbstractReplicationTest {
for (IgniteInternalFuture<?> cdcFut : cdcFuts) {
assertTrue(
"Waiting for clients fail and crash ignite-cdc",
- waitForCondition(cdcFut::isDone, getTestTimeout())
+ waitForCondition(cdcFut::isDone, 30_000)
);
}
}