[ignite] branch master updated: IGNITE-14620 Fix GridCacheAsyncOperationsLimitSelfTest#testAsyncOps flakiness

[pt...@apache.org]

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

ptupitsyn 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 255a30c  IGNITE-14620 Fix GridCacheAsyncOperationsLimitSelfTest#testAsyncOps flakiness
255a30c is described below

commit 255a30c0a9e95a0d444ce6a72d634e0963bc5097
Author: Pavel Tupitsyn <pt...@apache.org>
AuthorDate: Thu Apr 22 21:49:13 2021 +0300

    IGNITE-14620 Fix GridCacheAsyncOperationsLimitSelfTest#testAsyncOps flakiness
    
    Use synchronous future listener explicitly, because defaults changed in IGNITE-12033
---
 .../processors/cache/GridCacheAsyncOperationsLimitSelfTest.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAsyncOperationsLimitSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAsyncOperationsLimitSelfTest.java
index c4cf2e1..09fbb00 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAsyncOperationsLimitSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAsyncOperationsLimitSelfTest.java
@@ -58,7 +58,7 @@ public class GridCacheAsyncOperationsLimitSelfTest extends GridCacheAbstractSelf
 
             cnt.incrementAndGet();
 
-            jcache().putAsync("key" + i, i).listen(new CI1<IgniteFuture<?>>() {
+            jcache().putAsync("key" + i, i).listenAsync(new CI1<IgniteFuture<?>>() {
                 @Override public void apply(IgniteFuture<?> t) {
                     cnt.decrementAndGet();
 
@@ -67,7 +67,7 @@ public class GridCacheAsyncOperationsLimitSelfTest extends GridCacheAbstractSelf
                     if (i0 > 0 && i0 % 100 == 0)
                         info("cnt: " + cnt.get());
                 }
-            });
+            }, Runnable::run);
 
             assertTrue("Maximum number of permits exceeded: " + max.get(), max.get() <= 51);
         }