You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2020/02/14 00:16:46 UTC
[ignite] branch master updated: IGNITE-12667 Fixed flaky test
FailureProcessorThreadDumpThrottlingTest.testThrottlingPerFailureType
This is an automated email from the ASF dual-hosted git repository.
agura pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new c83e1e9 IGNITE-12667 Fixed flaky test FailureProcessorThreadDumpThrottlingTest.testThrottlingPerFailureType
c83e1e9 is described below
commit c83e1e9f5d2dc193f93a5ddbbf697c796b5ae08c
Author: Andrey Gura <ag...@apache.org>
AuthorDate: Thu Feb 6 19:45:08 2020 +0300
IGNITE-12667 Fixed flaky test FailureProcessorThreadDumpThrottlingTest.testThrottlingPerFailureType
---
.../FailureProcessorThreadDumpThrottlingTest.java | 26 +++++++++++-----------
1 file changed, 13 insertions(+), 13 deletions(-)
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/failure/FailureProcessorThreadDumpThrottlingTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/failure/FailureProcessorThreadDumpThrottlingTest.java
index 9f85ae6..6861c47 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/failure/FailureProcessorThreadDumpThrottlingTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/failure/FailureProcessorThreadDumpThrottlingTest.java
@@ -90,7 +90,7 @@ public class FailureProcessorThreadDumpThrottlingTest extends GridCommonAbstract
FailureContext failureCtx =
new FailureContext(SYSTEM_WORKER_BLOCKED, new Throwable("Failure context error"));
- for (int i = 0; i < 3; i++)
+ for (int i = 0; i < 2; i++)
ignite.context().failure().process(failureCtx);
assertTrue(lsnr.check());
@@ -103,7 +103,7 @@ public class FailureProcessorThreadDumpThrottlingTest extends GridCommonAbstract
@WithSystemProperty(key = IgniteSystemProperties.IGNITE_DUMP_THREADS_ON_FAILURE, value = "true")
@WithSystemProperty(key = IgniteSystemProperties.IGNITE_DUMP_THREADS_ON_FAILURE_THROTTLING_TIMEOUT, value = "0")
public void testNoThrottling() throws Exception {
- LogListener lsnr = LogListener.matches(THREAD_DUMP_MSG).times(3).build();
+ LogListener lsnr = LogListener.matches(THREAD_DUMP_MSG).times(2).build();
testLog.registerListener(lsnr);
@@ -112,7 +112,7 @@ public class FailureProcessorThreadDumpThrottlingTest extends GridCommonAbstract
FailureContext failureCtx =
new FailureContext(SYSTEM_WORKER_BLOCKED, new Throwable("Failure context error"));
- for (int i = 0; i < 3; i++)
+ for (int i = 0; i < 2; i++)
ignite.context().failure().process(failureCtx);
assertTrue(lsnr.check());
@@ -123,10 +123,10 @@ public class FailureProcessorThreadDumpThrottlingTest extends GridCommonAbstract
*/
@Test
@WithSystemProperty(key = IgniteSystemProperties.IGNITE_DUMP_THREADS_ON_FAILURE, value = "true")
- @WithSystemProperty(key = IgniteSystemProperties.IGNITE_DUMP_THREADS_ON_FAILURE_THROTTLING_TIMEOUT, value = "1000")
+ @WithSystemProperty(key = IgniteSystemProperties.IGNITE_DUMP_THREADS_ON_FAILURE_THROTTLING_TIMEOUT, value = "3000")
public void testThrottling() throws Exception {
LogListener dumpLsnr = LogListener.matches(THREAD_DUMP_MSG).times(2).build();
- LogListener throttledLsnr = LogListener.matches("Thread dump is hidden").times(4).build();
+ LogListener throttledLsnr = LogListener.matches("Thread dump is hidden").times(2).build();
testLog.registerListener(dumpLsnr);
testLog.registerListener(throttledLsnr);
@@ -136,12 +136,12 @@ public class FailureProcessorThreadDumpThrottlingTest extends GridCommonAbstract
FailureContext failureCtx =
new FailureContext(SYSTEM_WORKER_BLOCKED, new Throwable("Failure context error"));
- for (int i = 0; i < 3; i++)
+ for (int i = 0; i < 2; i++)
ignite.context().failure().process(failureCtx);
- U.sleep(1000);
+ U.sleep(3000);
- for (int i = 0; i < 3; i++)
+ for (int i = 0; i < 2; i++)
ignite.context().failure().process(failureCtx);
assertTrue(dumpLsnr.check());
@@ -153,10 +153,10 @@ public class FailureProcessorThreadDumpThrottlingTest extends GridCommonAbstract
*/
@Test
@WithSystemProperty(key = IgniteSystemProperties.IGNITE_DUMP_THREADS_ON_FAILURE, value = "true")
- @WithSystemProperty(key = IgniteSystemProperties.IGNITE_DUMP_THREADS_ON_FAILURE_THROTTLING_TIMEOUT, value = "1000")
+ @WithSystemProperty(key = IgniteSystemProperties.IGNITE_DUMP_THREADS_ON_FAILURE_THROTTLING_TIMEOUT, value = "3000")
public void testThrottlingPerFailureType() throws Exception {
LogListener dumpLsnr = LogListener.matches(THREAD_DUMP_MSG).times(4).build();
- LogListener throttledLsnr = LogListener.matches("Thread dump is hidden").times(8).build();
+ LogListener throttledLsnr = LogListener.matches("Thread dump is hidden").times(4).build();
testLog.registerListener(dumpLsnr);
testLog.registerListener(throttledLsnr);
@@ -169,15 +169,15 @@ public class FailureProcessorThreadDumpThrottlingTest extends GridCommonAbstract
FailureContext opTimeoutFailureCtx =
new FailureContext(SYSTEM_CRITICAL_OPERATION_TIMEOUT, new Throwable("Failure context error"));
- for (int i = 0; i < 3; i++) {
+ for (int i = 0; i < 2; i++) {
ignite.context().failure().process(workerBlockedFailureCtx);
ignite.context().failure().process(opTimeoutFailureCtx);
}
- U.sleep(1000);
+ U.sleep(3000);
- for (int i = 0; i < 3; i++) {
+ for (int i = 0; i < 2; i++) {
ignite.context().failure().process(workerBlockedFailureCtx);
ignite.context().failure().process(opTimeoutFailureCtx);