We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3c10ee6 commit f76cbc0Copy full SHA for f76cbc0
google-cloud-spanner/src/main/java/com/google/cloud/spanner/SessionImpl.java
@@ -305,7 +305,8 @@ public CommitResponse writeAtLeastOnceWithOptions(
305
try (IScope s = tracer.withSpan(span)) {
306
return SpannerRetryHelper.runTxWithRetriesOnAborted(
307
() -> {
308
- // TODO: Detect an abort and then refresh the reqId.
+ // TODO(@odeke-em): Only increment on UNAVAILABLE and INCREMENT,
309
+ // instead increment the nthRequest on ABORTED and others.
310
reqId.incrementAttempt();
311
return new CommitResponse(
312
spanner.getRpc().commit(request, reqId.withOptions(getOptions())));
0 commit comments