You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2022/03/02 21:55:39 UTC
[beam] branch master updated: Skipping flaky sad-path tests for Spanner changestreams
This is an automated email from the ASF dual-hosted git repository.
pabloem 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 e4bc643 Skipping flaky sad-path tests for Spanner changestreams
new c0f9eff Merge pull request #16993 from pabloem/fix-flake
e4bc643 is described below
commit e4bc64358ea3ba0385e4383313889c8e42a7ab8f
Author: Pablo Estrada <pa...@apache.org>
AuthorDate: Wed Mar 2 14:20:21 2022 -0500
Skipping flaky sad-path tests for Spanner changestreams
---
.../sdk/io/gcp/spanner/changestreams/SpannerChangeStreamErrorTest.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/SpannerChangeStreamErrorTest.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/SpannerChangeStreamErrorTest.java
index 34d7cd4..0509933 100644
--- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/SpannerChangeStreamErrorTest.java
+++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/SpannerChangeStreamErrorTest.java
@@ -62,6 +62,7 @@ import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.Immutabl
import org.hamcrest.Matchers;
import org.junit.After;
import org.junit.Before;
+import org.junit.Ignore;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.ExpectedException;
@@ -128,6 +129,7 @@ public class SpannerChangeStreamErrorTest implements Serializable {
}
@Test
+ @Ignore
public void testUnavailableExceptionRetries() {
mockSpannerService.setExecuteStreamingSqlExecutionTime(
SimulatedExecutionTime.ofExceptions(
@@ -206,6 +208,7 @@ public class SpannerChangeStreamErrorTest implements Serializable {
}
@Test
+ @Ignore
public void testInvalidRecordReceived() {
final Timestamp now = Timestamp.now();
final Timestamp after3Seconds =