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();

Reply via email to