Repository: apex-malhar Updated Branches: refs/heads/master c0af266ae -> 0a1adff8a
APEXMALHAR-2206: Fixed application tests. Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/0a1adff8 Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/0a1adff8 Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/0a1adff8 Branch: refs/heads/master Commit: 0a1adff8ab9c770b03cff76ddaffdc1ff8e06932 Parents: c0af266 Author: bhupeshchawda <[email protected]> Authored: Fri Aug 26 16:56:36 2016 +0530 Committer: bhupeshchawda <[email protected]> Committed: Fri Aug 26 19:01:21 2016 +0530 ---------------------------------------------------------------------- .../src/test/java/com/datatorrent/lib/db/jdbc/JdbcIOAppTest.java | 1 + .../java/org/apache/apex/malhar/lib/dedup/DeduperOrderingTest.java | 1 + .../org/apache/apex/malhar/lib/dedup/DeduperPartitioningTest.java | 1 + .../apache/apex/malhar/lib/join/POJOPartitionJoinOperatorTest.java | 1 + 4 files changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/0a1adff8/library/src/test/java/com/datatorrent/lib/db/jdbc/JdbcIOAppTest.java ---------------------------------------------------------------------- diff --git a/library/src/test/java/com/datatorrent/lib/db/jdbc/JdbcIOAppTest.java b/library/src/test/java/com/datatorrent/lib/db/jdbc/JdbcIOAppTest.java index 726595c..fe31f01 100644 --- a/library/src/test/java/com/datatorrent/lib/db/jdbc/JdbcIOAppTest.java +++ b/library/src/test/java/com/datatorrent/lib/db/jdbc/JdbcIOAppTest.java @@ -126,6 +126,7 @@ public class JdbcIOAppTest Thread.sleep(3000); Assert.assertEquals("Events in store", 10, getNumOfEventsInStore()); + lc.shutdown(); } catch (ConstraintViolationException e) { Assert.fail("constraint violations: " + e.getConstraintViolations()); http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/0a1adff8/library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperOrderingTest.java ---------------------------------------------------------------------- diff --git a/library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperOrderingTest.java b/library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperOrderingTest.java index 544c1df..b4f76a6 100644 --- a/library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperOrderingTest.java +++ b/library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperOrderingTest.java @@ -109,6 +109,7 @@ public class DeduperOrderingTest TestPojo pojo = new TestPojo(sequenceId, new Date(), sequenceId); output.emit(pojo); sequenceId++; + windowCount++; } } } http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/0a1adff8/library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperPartitioningTest.java ---------------------------------------------------------------------- diff --git a/library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperPartitioningTest.java b/library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperPartitioningTest.java index ebe5a3e..9594e63 100644 --- a/library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperPartitioningTest.java +++ b/library/src/test/java/org/apache/apex/malhar/lib/dedup/DeduperPartitioningTest.java @@ -191,5 +191,6 @@ public class DeduperPartitioningTest lc.runAsync(); app.dedup.latch.await(); Assert.assertFalse(testFailed); + lc.shutdown(); } } http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/0a1adff8/library/src/test/java/org/apache/apex/malhar/lib/join/POJOPartitionJoinOperatorTest.java ---------------------------------------------------------------------- diff --git a/library/src/test/java/org/apache/apex/malhar/lib/join/POJOPartitionJoinOperatorTest.java b/library/src/test/java/org/apache/apex/malhar/lib/join/POJOPartitionJoinOperatorTest.java index 9f6161b..89a1068 100644 --- a/library/src/test/java/org/apache/apex/malhar/lib/join/POJOPartitionJoinOperatorTest.java +++ b/library/src/test/java/org/apache/apex/malhar/lib/join/POJOPartitionJoinOperatorTest.java @@ -189,6 +189,7 @@ public class POJOPartitionJoinOperatorTest lc.runAsync(); app.joinOp.latch.await(); Assert.assertFalse(testFailed); + lc.shutdown(); } }
