IGNITE-10321 Fix flaky test CacheContinuousWithTransformerReplicatedSelfTest.LocalEventListener - Fixes #5427.
Signed-off-by: Dmitriy Govorukhin <dmitriy.govoruk...@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...@gmail.com> Authored: Mon Nov 19 17:02:48 2018 +0300 Committer: Dmitriy Govorukhin <dmitriy.govoruk...@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(); } } }
