Repository: incubator-ignite Updated Branches: refs/heads/ignite-426 eee8ea416 -> daa90987f
# ignite-426 add tests Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/daa90987 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/daa90987 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/daa90987 Branch: refs/heads/ignite-426 Commit: daa90987f08a91847af895a275e594dca167fb5a Parents: eee8ea4 Author: sboikov <sboi...@gridgain.com> Authored: Thu Aug 13 15:55:24 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu Aug 13 15:55:24 2015 +0300 ---------------------------------------------------------------------- .../cache/query/continuous/CacheContinuousQueryBatchAck.java | 3 +++ .../cache/query/continuous/CacheContinuousQueryHandler.java | 3 +++ .../continuous/CacheContinuousQueryFailoverAbstractTest.java | 6 +++--- 3 files changed, 9 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/daa90987/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryBatchAck.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryBatchAck.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryBatchAck.java index 49c1a3f..bfd1844 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryBatchAck.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryBatchAck.java @@ -30,6 +30,9 @@ import java.util.*; * Batch acknowledgement. */ public class CacheContinuousQueryBatchAck extends GridCacheMessage { + /** */ + private static final long serialVersionUID = 0L; + /** Routine ID. */ private UUID routineId; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/daa90987/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java index 98e857b..2f6fcaf 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java @@ -732,6 +732,9 @@ class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler { * */ private class DuplicateEventFilter implements IgnitePredicate<CacheContinuousQueryEntry> { + /** */ + private static final long serialVersionUID = 0L; + /** {@inheritDoc} */ @Override public boolean apply(CacheContinuousQueryEntry e) { return notifyListener(e); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/daa90987/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractTest.java index 3afb01c..e3ad025 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractTest.java @@ -180,7 +180,7 @@ public abstract class CacheContinuousQueryFailoverAbstractTest extends GridCommo QueryCursor<?> cur = qryClientCache.query(qry); - int PARTS = 1; + int PARTS = 10; for (int i = 0; i < SRV_NODES - 1; i++) { log.info("Stop iteration: " + i); @@ -261,7 +261,7 @@ public abstract class CacheContinuousQueryFailoverAbstractTest extends GridCommo int[] nodeParts = aff.primaryPartitions(node); - final int KEYS_PER_PART = 2; + final int KEYS_PER_PART = 3; for (int i = 0; i < parts; i++) { int part = nodeParts[i]; @@ -395,7 +395,7 @@ public abstract class CacheContinuousQueryFailoverAbstractTest extends GridCommo @Override public boolean apply() { return backupQueue.isEmpty(); } - }, 2000); + }, 3000); assertTrue("Backup queue is not cleared: " + backupQueue, backupQueue.isEmpty());
