You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by se...@apache.org on 2015/05/15 12:48:57 UTC

incubator-ignite git commit: IGNITE-836 Fix GridEventConsumeSelfTest

Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-709_2 784c088ec -> 63fc5e7b9


IGNITE-836 Fix GridEventConsumeSelfTest


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

Branch: refs/heads/ignite-709_2
Commit: 63fc5e7b91ff9ad440d1c49606cd432593c67dd7
Parents: 784c088
Author: sevdokimov <se...@gridgain.com>
Authored: Fri May 15 13:48:49 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Fri May 15 13:48:49 2015 +0300

----------------------------------------------------------------------
 .../internal/processors/continuous/GridEventConsumeSelfTest.java  | 3 ---
 1 file changed, 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/63fc5e7b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
index d219a60..63ec6d6 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
@@ -115,10 +115,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest implements
             assertEquals(0, localRoutines(proc).size());
             assertEquals(0, U.<Map>field(proc, "rmtInfos").size());
             assertEquals(0, U.<Map>field(proc, "startFuts").size());
-            assertEquals(0, U.<Map>field(proc, "waitForStartAck").size());
             assertEquals(0, U.<Map>field(proc, "stopFuts").size());
-            assertEquals(0, U.<Map>field(proc, "waitForStopAck").size());
-            assertEquals(0, U.<Map>field(proc, "pending").size());
         }
     }