File tree Expand file tree Collapse file tree
cdap-storage-ext-spanner/src/main/java/io/cdap/cdap/storage/spanner Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1717package io .cdap .cdap .storage .spanner ;
1818
1919import com .google .cloud .spanner .ErrorCode ;
20+ import com .google .cloud .spanner .Options ;
2021import com .google .cloud .spanner .SpannerException ;
2122import io .cdap .cdap .spi .data .transaction .TransactionException ;
2223import io .cdap .cdap .spi .data .transaction .TransactionRunner ;
@@ -36,7 +37,7 @@ public SpannerTransactionRunner(SpannerStructuredTableAdmin admin) {
3637 @ Override
3738 public void run (TxRunnable runnable ) throws TransactionException {
3839 try {
39- admin .getDatabaseClient ().readWriteTransaction ().allowNestedTransaction ().run (context -> {
40+ admin .getDatabaseClient ().readWriteTransaction (Options . optimisticLock () ).allowNestedTransaction ().run (context -> {
4041 runnable .run (new SpannerStructuredTableContext (context , admin ));
4142 return null ;
4243 });
You can’t perform that action at this time.
0 commit comments