Parallel calls

sumeet-db · Sep 6, 2024 · 3aa3bd9 · 3aa3bd9
1 parent d59e3f0
commit 3aa3bd9
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 79 deletions.
diff --git a/spark/src/main/java/io/delta/dynamodbcommitcoordinator/CoordinatedCommitsUtils.java b/spark/src/main/java/io/delta/dynamodbcommitcoordinator/CoordinatedCommitsUtils.java
diff --git a/...orage/commit/CoordinatedCommitsUtils.java → ...orage/commit/CoordinatedCommitsUtils.java b/...orage/commit/CoordinatedCommitsUtils.java → ...orage/commit/CoordinatedCommitsUtils.java
@@ -35,8 +35,8 @@ private CoordinatedCommitsUtils() {}
     /** The subdirectory in which to store the unbackfilled commit files. */
     final static String COMMIT_SUBDIR = "_commits";
 
-    /** The configuration key for the coordinated commits owner. */
-    private static final String COORDINATED_COMMITS_COORDINATOR_CONF_KEY =
+    /** The configuration key for the coordinated commits owner name. */
+    private static final String COORDINATED_COMMITS_COORDINATOR_NAME_KEY =
             "delta.coordinatedCommits.commitCoordinator-preview";
 
     /**
@@ -111,7 +111,7 @@ public static Path commitDirPath(Path logPath) {
     private static String getCoordinator(AbstractMetadata metadata) {
         String coordinator = metadata
                 .getConfiguration()
-                .get(COORDINATED_COMMITS_COORDINATOR_CONF_KEY);
+                .get(COORDINATED_COMMITS_COORDINATOR_NAME_KEY);
         return coordinator != null ? coordinator : "";
     }
 }
diff --git a/storage/src/test/scala/io/delta/storage/commit/InMemoryCommitCoordinator.scala b/storage/src/test/scala/io/delta/storage/commit/InMemoryCommitCoordinator.scala
@@ -22,6 +22,7 @@ import java.util.concurrent.ConcurrentHashMap
 import java.util.concurrent.locks.ReentrantReadWriteLock
 
 import io.delta.storage.LogStore
+import io.delta.storage.commit.CoordinatedCommitsUtils
 import io.delta.storage.commit.actions.AbstractMetadata
 import io.delta.storage.commit.actions.AbstractProtocol
 import org.apache.hadoop.conf.Configuration