This repository was archived by the owner on Apr 7, 2026. It is now read-only.
File tree Expand file tree Collapse file tree
google-cloud-spanner/src/main/java/com/google/cloud/spanner Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -305,9 +305,6 @@ public CommitResponse writeAtLeastOnceWithOptions(
305305 try (IScope s = tracer .withSpan (span )) {
306306 return SpannerRetryHelper .runTxWithRetriesOnAborted (
307307 () -> {
308- // TODO(@odeke-em): Only increment on UNAVAILABLE and INCREMENT,
309- // instead increment the nthRequest on ABORTED and others.
310- reqId .incrementAttempt ();
311308 return new CommitResponse (
312309 spanner .getRpc ().commit (request , reqId .withOptions (getOptions ())));
313310 });
@@ -322,7 +319,7 @@ public CommitResponse writeAtLeastOnceWithOptions(
322319 private XGoogSpannerRequestId reqIdOrFresh (Options options ) {
323320 XGoogSpannerRequestId reqId = options .reqId ();
324321 if (reqId == null ) {
325- reqId = this .getRequestIdCreator ().nextRequestId (1 /* TODO: channelId */ , 0 );
322+ reqId = this .getRequestIdCreator ().nextRequestId (1 /* TODO: channelId */ , 1 );
326323 }
327324 return reqId ;
328325 }
You can’t perform that action at this time.
0 commit comments