Ignore system worker block failure in test
package org.apache.ignite.internal.processors.cache.persistence.wal;
+import org.apache.ignite.Ignite;
import org.apache.ignite.configuration.DataRegionConfiguration;
import org.apache.ignite.configuration.DataStorageConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
+import org.apache.ignite.failure.FailureContext;
import org.apache.ignite.failure.FailureHandler;
+import org.apache.ignite.failure.FailureType;
import org.apache.ignite.failure.StopNodeFailureHandler;
import org.apache.ignite.internal.processors.cache.persistence.wal.memtracker.PageMemoryTrackerConfiguration;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
@@ -52,7 +55,16 @@ public abstract class AbstractWalDeltaConsistencyTest extends GridCommonAbstract
/** {@inheritDoc} */
@Override protected FailureHandler getFailureHandler(String igniteInstanceName) {
- return checkPagesOnCheckpoint() ? new StopNodeFailureHandler() : super.getFailureHandler(igniteInstanceName);
+ return checkPagesOnCheckpoint() ?
+ new StopNodeFailureHandler() {
+ @Override public boolean handle(Ignite ignite, FailureContext failureCtx) {
+ if (failureCtx.type() == FailureType.SYSTEM_WORKER_BLOCKED)
+ return false;
+
+ return super.handle(ignite, failureCtx);
+ }
+ } :
+ super.getFailureHandler(igniteInstanceName);
}
/**
