Fixed threads cleanup in continuous processor
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/8ecddcc2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/8ecddcc2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/8ecddcc2 Branch: refs/heads/ignite-426 Commit: 8ecddcc2dcb064b759486d43a4f09173f268b3cf Parents: 260238e Author: Valentin Kulichenko <valentin.kuliche...@gmail.com> Authored: Thu Aug 13 16:25:09 2015 -0700 Committer: Valentin Kulichenko <valentin.kuliche...@gmail.com> Committed: Thu Aug 13 16:25:09 2015 -0700 ---------------------------------------------------------------------- .../internal/processors/continuous/GridEventConsumeSelfTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8ecddcc2/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 5ce2efd..7ab858b 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 @@ -26,7 +26,6 @@ import org.apache.ignite.internal.util.*; import org.apache.ignite.internal.util.typedef.*; import org.apache.ignite.internal.util.typedef.internal.*; import org.apache.ignite.lang.*; -import org.apache.ignite.marshaller.optimized.*; import org.apache.ignite.resources.*; import org.apache.ignite.spi.discovery.tcp.*; import org.apache.ignite.spi.discovery.tcp.ipfinder.*; @@ -125,6 +124,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest { assertEquals(0, U.<Map>field(proc, "rmtInfos").size()); assertEquals(0, U.<Map>field(proc, "startFuts").size()); assertEquals(0, U.<Map>field(proc, "stopFuts").size()); + assertEquals(0, U.<Map>field(proc, "bufCheckThreads").size()); } } finally { @@ -754,7 +754,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest { */ public void testNodeJoinWithP2P() throws Exception { fail("https://issues.apache.org/jira/browse/IGNITE-585";); - + final Collection<UUID> nodeIds = new HashSet<>(); final AtomicInteger cnt = new AtomicInteger(); final CountDownLatch latch = new CountDownLatch(GRID_CNT + 1);
