Skip to content

Commit f160628

Browse files
shunpingjiangzzhu
andauthored
[Release-2.70] Cherry-pick #36995 and #37003 (#37017)
* Temporary disable a few unit tests in SpannerChangeStreamErrorTest (#37003) * Update spanner client version. (#36995) * Update spanner client version. * Edit comments with a new issue id. --------- Co-authored-by: Jiang Zhu <[email protected]>
1 parent fecd5e1 commit f160628

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -612,8 +612,8 @@ class BeamModulePlugin implements Plugin<Project> {
612612
def google_ads_version = "33.0.0"
613613
def google_clients_version = "2.0.0"
614614
def google_cloud_bigdataoss_version = "2.2.26"
615-
// [bomupgrader] TODO(#35868): currently pinned, should be determined by: com.google.cloud:google-cloud-spanner, consistent with: google_cloud_platform_libraries_bom
616-
def google_cloud_spanner_version = "6.95.1"
615+
// [bomupgrader] TODO(#37008): currently pinned before gcp-bom moving beyond this version, should be determined by: com.google.cloud:google-cloud-spanner, consistent with: google_cloud_platform_libraries_bom
616+
def google_cloud_spanner_version = "6.104.0"
617617
def google_code_gson_version = "2.10.1"
618618
def google_oauth_clients_version = "1.34.1"
619619
// [bomupgrader] determined by: io.grpc:grpc-netty, consistent with: google_cloud_platform_libraries_bom

sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/SpannerChangeStreamErrorTest.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,7 @@
7070
import org.joda.time.Duration;
7171
import org.junit.After;
7272
import org.junit.Before;
73+
import org.junit.Ignore;
7374
import org.junit.Rule;
7475
import org.junit.Test;
7576
import org.junit.rules.ExpectedException;
@@ -115,6 +116,7 @@ public void tearDown() throws NoSuchFieldException, IllegalAccessException {
115116
}
116117

117118
@Test
119+
@Ignore("https://github.com/apache/beam/issues/37002 Re-enable skipped tests.")
118120
// Error code UNAVAILABLE is retried repeatedly until the RPC times out.
119121
public void testUnavailableExceptionRetries() throws InterruptedException {
120122
DirectOptions options = PipelineOptionsFactory.as(DirectOptions.class);
@@ -155,6 +157,7 @@ public void testUnavailableExceptionRetries() throws InterruptedException {
155157
}
156158

157159
@Test
160+
@Ignore("https://github.com/apache/beam/issues/37002 Re-enable skipped tests.")
158161
// Error code ABORTED is retried repeatedly until it times out.
159162
public void testAbortedExceptionRetries() throws InterruptedException {
160163
mockSpannerService.setExecuteStreamingSqlExecutionTime(
@@ -218,6 +221,7 @@ public void testUnknownExceptionDoesNotRetry() {
218221
}
219222

220223
@Test
224+
@Ignore("https://github.com/apache/beam/issues/37002 Re-enable skipped tests.")
221225
// Error code RESOURCE_EXHAUSTED is retried repeatedly.
222226
public void testResourceExhaustedRetry() {
223227
mockSpannerService.setExecuteStreamingSqlExecutionTime(
@@ -281,6 +285,7 @@ public void testResourceExhaustedRetryWithDefaultSettings() {
281285
}
282286

283287
@Test
288+
@Ignore("https://github.com/apache/beam/issues/37002 Re-enable skipped tests.")
284289
public void testInvalidRecordReceived() {
285290
final Timestamp startTimestamp = Timestamp.ofTimeSecondsAndNanos(0, 1000);
286291
final Timestamp endTimestamp =

0 commit comments

Comments
 (0)