Repository: apex-malhar Updated Branches: refs/heads/master 999efccba -> 87d8aef7c
APEXMALHAR-2315 Ignore tests in sql which uses POJOInnerJoinOperator for SQL JOIN functionality. This should be reverted once POJOInnerJoinOperator is replaced with Windowed variant of it. Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/87d8aef7 Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/87d8aef7 Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/87d8aef7 Branch: refs/heads/master Commit: 87d8aef7c11a98aad0152655c5ea79a6358b87dd Parents: 999efcc Author: Chinmay Kolhatkar <[email protected]> Authored: Tue Oct 25 12:05:50 2016 +0530 Committer: Chinmay Kolhatkar <[email protected]> Committed: Wed Oct 26 11:16:50 2016 +0530 ---------------------------------------------------------------------- .../test/java/org/apache/apex/malhar/sql/KafkaEndpointTest.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/87d8aef7/sql/src/test/java/org/apache/apex/malhar/sql/KafkaEndpointTest.java ---------------------------------------------------------------------- diff --git a/sql/src/test/java/org/apache/apex/malhar/sql/KafkaEndpointTest.java b/sql/src/test/java/org/apache/apex/malhar/sql/KafkaEndpointTest.java index 14eff70..8c816b3 100644 --- a/sql/src/test/java/org/apache/apex/malhar/sql/KafkaEndpointTest.java +++ b/sql/src/test/java/org/apache/apex/malhar/sql/KafkaEndpointTest.java @@ -27,6 +27,7 @@ import java.util.TimeZone; import org.junit.After; import org.junit.Assert; import org.junit.Before; +import org.junit.Ignore; import org.junit.Test; import org.apache.apex.malhar.kafka.EmbeddedKafka; @@ -135,6 +136,7 @@ public class KafkaEndpointTest } } + @Ignore("Skipping because POJOInnerJoinOperator has issues and needs to be replaced with Windowed variant first.") @Test public void testApplicationJoin() throws Exception { @@ -176,6 +178,7 @@ public class KafkaEndpointTest } } + @Ignore("Skipping because POJOInnerJoinOperator has issues and needs to be replaced with Windowed variant first.") @Test public void testApplicationJoinFilter() throws Exception {
