ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: # ignite-426 add tests
Date Thu, 13 Aug 2015 12:55:44 GMT
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 <sboikov@gridgain.com>
Authored: Thu Aug 13 15:55:24 2015 +0300
Committer: sboikov <sboikov@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());
 


Mime
View raw message