diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/util/Errors.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/util/Errors.java
index d57bb3f11f..067f8d242d 100644
--- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/util/Errors.java
+++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/util/Errors.java
@@ -31,7 +31,7 @@ public static boolean isRetryableInternalStatus(Status status) {
     String description = status.getDescription();
     return status.getCode() == Status.Code.INTERNAL
         && description != null
-        && (description.contains("Received unexpected EOS on DATA frame from server")
+        && (description.contains("Received unexpected EOS ")
             || description.contains(" Rst ")
             || description.contains("RST_STREAM")
             || description.contains("Connection closed with unknown cause")