From d82fb2b4c81f960fe62721e1972652018a3507de Mon Sep 17 00:00:00 2001 From: Akarys Shorabek Date: Thu, 6 Mar 2025 16:24:23 +0500 Subject: [PATCH] Remove retry count assertion from testInvalidRecordReceived --- .../spanner/changestreams/SpannerChangeStreamErrorTest.java | 5 ----- 1 file changed, 5 deletions(-) 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 d1f65d9f75a3..c753eb7da5f2 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 @@ -316,11 +316,6 @@ public void testInvalidRecordReceived() { // DatabaseClient.getDialect returns "DEADLINE_EXCEEDED: Operation did not complete in the " // given time" even though we mocked it out. thrown.expectMessage("DEADLINE_EXCEEDED"); - // Allow for at most two retry requests; - int requestThreshold = 2; - assertThat( - mockSpannerService.countRequestsOfType(ExecuteSqlRequest.class), - Matchers.lessThanOrEqualTo(requestThreshold)); } }