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 <[email protected]>
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();