Parallel calls

sumeet-db · Nov 5, 2024 · 3cb64c7 · 3cb64c7
1 parent cd0c19d
commit 3cb64c7
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...est/scala/org/apache/spark/sql/delta/coordinatedcommits/InMemoryUCCommitCoordinator.scala b/...est/scala/org/apache/spark/sql/delta/coordinatedcommits/InMemoryUCCommitCoordinator.scala
@@ -25,11 +25,13 @@ import java.util.concurrent.locks.ReentrantReadWriteLock
 import scala.collection.JavaConverters._
 import scala.collection.mutable
 
-import com.databricks.sql.managedcatalog.TableId
 import org.apache.spark.sql.delta.DeltaTableUtils
 import org.apache.spark.sql.delta.actions.{Metadata, Protocol}
 import org.apache.spark.sql.delta.util.FileNames
-import io.delta.storage.commit.{Commit => JCommit, GetCommitsResponse => JGetCommitsResponse}
+import io.delta.storage.commit.{
+  Commit => JCommit,
+  CommitFailedException => JCommitFailedException,
+  GetCommitsResponse => JGetCommitsResponse}
 import io.delta.storage.commit.uccommitcoordinator.{CommitLimitReachedException => JCommitLimitReachedException, InvalidTargetTableException => JInvalidTargetTableException}
 import org.apache.hadoop.fs.{FileStatus, Path}