ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [28/50] [abbrv] ignite git commit: IGNITE-10321 Fix flaky test CacheContinuousWithTransformerReplicatedSelfTest.LocalEventListener - Fixes #5427.
Date Tue, 20 Nov 2018 18:04:21 GMT
IGNITE-10321 Fix flaky test CacheContinuousWithTransformerReplicatedSelfTest.LocalEventListener
- Fixes #5427.

Signed-off-by: Dmitriy Govorukhin <dmitriy.govorukhin@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c711d4f6
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c711d4f6
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c711d4f6

Branch: refs/heads/ignite-9720
Commit: c711d4f6f7ecc6ad59643a2a82d7d487d8d45a90
Parents: acfdcda
Author: ibessonov <bessonov.ip@gmail.com>
Authored: Mon Nov 19 17:02:48 2018 +0300
Committer: Dmitriy Govorukhin <dmitriy.govorukhin@gmail.com>
Committed: Mon Nov 19 17:02:48 2018 +0300

----------------------------------------------------------------------
 .../CacheContinuousWithTransformerReplicatedSelfTest.java        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/c711d4f6/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousWithTransformerReplicatedSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousWithTransformerReplicatedSelfTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousWithTransformerReplicatedSelfTest.java
index 60e2f80..3768aad 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousWithTransformerReplicatedSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousWithTransformerReplicatedSelfTest.java
@@ -492,10 +492,10 @@ public class CacheContinuousWithTransformerReplicatedSelfTest extends
GridCommon
         /** {@inheritDoc} */
         @Override public void onUpdated(Iterable<? extends String> events) throws CacheEntryListenerException
{
             for (String evt : events) {
+                cnt.incrementAndGet();
+
                 if (evt.startsWith(SARAH_CONNOR))
                     cntLatch.countDown();
-
-                cnt.incrementAndGet();
             }
         }
     }


Mime
View raw message