commit c83e1e9f5d2dc193f93a5ddbbf697c796b5ae08c
author Andrey Gura <agura@apache.org> Thu Feb 06 19:45:08 2020 +0300
committer Andrey Gura <agura@apache.org> Fri Feb 14 03:08:18 2020 +0300
tree 2a788446997f9e327fb2827b26598b49451c7d74
parent ffde253144dfb28411a2ded012291756cd447a2d

IGNITE-12667 Fixed flaky test FailureProcessorThreadDumpThrottlingTest.testThrottlingPerFailureType

modules/core/src/test/java/org/apache/ignite/internal/processors/failure/FailureProcessorThreadDumpThrottlingTest.java

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 @@
         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 @@
     @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 @@
         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 @@
      */
     @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 @@
         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 @@
      */
     @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 @@
         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);