Trying IsolationLevel.SERIALIZABLE

Author: sahusanket

cdap-storage-ext-spanner/pom.xml

@@ -39,7 +39,7 @@
       <dependency>
         <groupId>com.google.cloud</groupId>
         <artifactId>libraries-bom</artifactId>
-        <version>26.55.0</version>
+        <version>26.78.0</version>
         <type>pom</type>
         <scope>import</scope>
       </dependency>

cdap-storage-ext-spanner/src/main/java/io/cdap/cdap/storage/spanner/SpannerStorageProvider.java

@@ -21,6 +21,8 @@
 import com.google.cloud.spanner.InstanceId;
 import com.google.cloud.spanner.Spanner;
 import com.google.cloud.spanner.SpannerOptions;
+import com.google.cloud.spanner.SpannerOptions.Builder.DefaultReadWriteTransactionOptions;
+import com.google.spanner.v1.TransactionOptions.IsolationLevel;
 import io.cdap.cdap.spi.data.StorageProvider;
 import io.cdap.cdap.spi.data.StorageProviderContext;
 import io.cdap.cdap.spi.data.StructuredTableAdmin;
@@ -77,7 +79,13 @@ public void initialize(StorageProviderContext context) throws Exception {
       throw new IllegalArgumentException("Missing configuration " + DATABASE);
     }
 
-    SpannerOptions.Builder builder = SpannerOptions.newBuilder().setProjectId(project);
+    DefaultReadWriteTransactionOptions transactionOptions =
+        DefaultReadWriteTransactionOptions.newBuilder()
+            .setIsolationLevel(IsolationLevel.SERIALIZABLE)
+            .build();
+
+    SpannerOptions.Builder builder = SpannerOptions.newBuilder()
+        .setDefaultTransactionOptions(transactionOptions).setProjectId(project);
 
     String credentialsPath = conf.get(CREDENTIALS_PATH);
     if (credentialsPath != null) {