Skip to content

Commit 543373b

Browse files
authored
fix: set default values for streaming retry (#316)
1 parent 122a997 commit 543373b

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

google-cloud-spanner/src/main/java/com/google/cloud/spanner/AbstractResultSet.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -855,8 +855,9 @@ private static ExponentialBackOff newBackOff() {
855855
return new ExponentialBackOff.Builder()
856856
.setMultiplier(STREAMING_RETRY_SETTINGS.getRetryDelayMultiplier())
857857
.setInitialIntervalMillis(
858-
(int) STREAMING_RETRY_SETTINGS.getInitialRetryDelay().toMillis())
859-
.setMaxIntervalMillis((int) STREAMING_RETRY_SETTINGS.getMaxRetryDelay().toMillis())
858+
Math.max(10, (int) STREAMING_RETRY_SETTINGS.getInitialRetryDelay().toMillis()))
859+
.setMaxIntervalMillis(
860+
Math.max(1000, (int) STREAMING_RETRY_SETTINGS.getMaxRetryDelay().toMillis()))
860861
.setMaxElapsedTimeMillis(Integer.MAX_VALUE) // Prevent Backoff.STOP from getting returned.
861862
.build();
862863
}

0 commit comments

Comments
 (0)