beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From an...@apache.org
Subject [beam] branch master updated: [SQL] Disable KafkaCSVTableIT
Date Mon, 12 Aug 2019 22:46:57 GMT
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 <kedin@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();


Mime
View raw message