Treat RESOURCE_EXHAUSTED with retry information as aborted.#2645
Conversation
| * Return the retry delay for transaction in milliseconds. Return -1 if this does not specify any | ||
| * retry delay. In that case, clients should fall back to a locally computed retry delay. | ||
| */ | ||
| public static long extractRetryDelay(Throwable cause) { |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| * Return the retry delay for transaction in milliseconds. Return -1 if this does not specify any | ||
| * retry delay. In that case, clients should fall back to a locally computed retry delay. | ||
| */ | ||
| public static long extractRetryDelay(Throwable cause) { |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
|
|
||
| /** | ||
| * Return the retry delay for transaction in milliseconds. Return -1 if this does not specify any | ||
| * retry delay. In that case, clients should fall back to a locally computed retry delay. |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| /** | ||
| * Return the retry delay for transaction in milliseconds. Return -1 if this does not specify any | ||
| * retry delay. In that case, clients should fall back to a locally computed retry delay. | ||
| */ |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| delay = ((AbortedException) e).getRetryDelayInMillis(); | ||
| } | ||
| long delay = SpannerException.extractRetryDelay(e.getCause()); | ||
| if (e.getErrorCode() == ErrorCode.ABORTED || (e.getErrorCode() == |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| /** | ||
| * Return the retry delay for transaction in milliseconds. Return -1 if this does not specify any | ||
| * retry delay. In that case, clients should fall back to a locally computed retry delay. | ||
| */ |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
|
|
||
| /** | ||
| * Return the retry delay for transaction in milliseconds. Return -1 if this does not specify any | ||
| * retry delay. In that case, clients should fall back to a locally computed retry delay. |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| * Return the retry delay for transaction in milliseconds. Return -1 if this does not specify any | ||
| * retry delay. In that case, clients should fall back to a locally computed retry delay. | ||
| */ | ||
| public static long extractRetryDelay(Throwable cause) { |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| * Return the retry delay for transaction in milliseconds. Return -1 if this does not specify any | ||
| * retry delay. In that case, clients should fall back to a locally computed retry delay. | ||
| */ | ||
| public static long extractRetryDelay(Throwable cause) { |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| } | ||
|
|
||
| /** | ||
| * Return the retry delay for transaction in milliseconds. Return -1 if this does not specify any |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| trailers.put(key, retryInfo); | ||
| SpannerException e = | ||
| SpannerExceptionFactory.newSpannerException(new StatusRuntimeException(status, trailers)); | ||
| assertThat(e.isRetryable()).isTrue(); |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
* chore(main): release 3.9.2 * chore: generate libraries at Thu Sep 26 15:09:07 UTC 2024 --------- Co-authored-by: release-please[bot] <55107282+release-please[bot]@users.noreply.github.com> Co-authored-by: cloud-java-bot <[email protected]>
In this PR: - Do not generate pr_description.txt if googleapis commit is the same in baseline config and current config.
…ge instance in GRPC test (#2645) * test: Fix storage closure * test: turn directpath sample test back on * use storage options instead of storage to avoid the need to close storage
) * feat: add port as a parameter for the bigtable emulator * chore: generate libraries at Wed Jul 16 21:29:57 UTC 2025 * set the port in emulator class --------- Co-authored-by: André Barbosa Sampaio <[email protected]> Co-authored-by: cloud-java-bot <[email protected]>
No description provided.