This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git
commit c48d03213e5848aec8217d9b136ecc153d1d1d3c Author: Etienne Chauchot <[email protected]> AuthorDate: Fri Sep 27 10:41:55 2019 +0200 Ignore long time failing test: SparkMetricsSinkTest --- .../aggregators/metrics/sink/SparkMetricsSinkTest.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/runners/spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/aggregators/metrics/sink/SparkMetricsSinkTest.java b/runners/spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/aggregators/metrics/sink/SparkMetricsSinkTest.java index dd23c05..9d56f0c 100644 --- a/runners/spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/aggregators/metrics/sink/SparkMetricsSinkTest.java +++ b/runners/spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/aggregators/metrics/sink/SparkMetricsSinkTest.java @@ -30,6 +30,7 @@ import org.apache.beam.sdk.transforms.MapElements; import org.apache.beam.sdk.values.PCollection; import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableList; import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableSet; +import org.junit.Ignore; import org.junit.Rule; import org.junit.Test; import org.junit.rules.ExternalResource; @@ -40,6 +41,7 @@ import org.junit.rules.ExternalResource; * <p>A test that verifies Beam metrics are reported to Spark's metrics sink in both batch and * streaming modes. */ +@Ignore ("Has been failing since at least c350188ef7a8704c7336f3c20a1ab2144abbcd4a") public class SparkMetricsSinkTest { @Rule public ExternalResource inMemoryMetricsSink = new InMemoryMetricsSinkRule(); @Rule public final TestPipeline pipeline = TestPipeline.create();
