This is an automated email from the ASF dual-hosted git repository. anton pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push: new f7eb6fe [SQL] Disable KafkaCSVTableIT new de18f4b Merge pull request #9322 from akedin/disable-kafkatableit f7eb6fe is described below commit f7eb6fe4eaddfdf393fb829f4eb920bdb5b2c979 Author: akedin <ke...@google.com> AuthorDate: Mon Aug 12 15:10:52 2019 -0700 [SQL] Disable KafkaCSVTableIT --- .../beam/sdk/extensions/sql/meta/provider/kafka/KafkaCSVTableIT.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaCSVTableIT.java b/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaCSVTableIT.java index 201a1df..1d71621 100644 --- a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaCSVTableIT.java +++ b/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaCSVTableIT.java @@ -60,6 +60,7 @@ import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerRecord; import org.junit.Assert; import org.junit.BeforeClass; +import org.junit.Ignore; import org.junit.Rule; import org.junit.Test; @@ -67,6 +68,7 @@ import org.junit.Test; * This is an integration test for KafkaCSVTable. There should be a kafka server running and the * address should be passed to it. (https://issues.apache.org/jira/projects/BEAM/issues/BEAM-7523) */ +@Ignore("https://issues.apache.org/jira/projects/BEAM/issues/BEAM-7523") public class KafkaCSVTableIT { @Rule public transient TestPipeline pipeline = TestPipeline.create();