diff --git a/plugin/trino-bigquery/src/main/java/io/trino/plugin/bigquery/ReadSessionCreator.java b/plugin/trino-bigquery/src/main/java/io/trino/plugin/bigquery/ReadSessionCreator.java index 97b94e556bae..b0c8e9711e47 100644 --- a/plugin/trino-bigquery/src/main/java/io/trino/plugin/bigquery/ReadSessionCreator.java +++ b/plugin/trino-bigquery/src/main/java/io/trino/plugin/bigquery/ReadSessionCreator.java @@ -113,7 +113,7 @@ public ReadSession create(ConnectorSession session, TableId remoteTable, List log.debug("Request failed, retrying: %s", event.getLastException())) - .abortOn(failure -> !BigQueryUtil.isRetryable(failure)) + .handleIf(BigQueryUtil::isRetryable) .build()) .get(() -> { try {