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));
     }
   }