Nit

sumeet-db · Mar 28, 2024 · e9a6816 · e9a6816
1 parent be0ffcc
commit e9a6816
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/spark/src/main/scala/org/apache/spark/sql/delta/OptimisticTransaction.scala b/spark/src/main/scala/org/apache/spark/sql/delta/OptimisticTransaction.scala
@@ -1376,7 +1376,7 @@ trait OptimisticTransactionImpl extends TransactionalWrite
           "delta.commitLarge.failure",
           data = Map("exception" -> Utils.exceptionString(ex),
             "operation" -> op.name,
-            "fromManagedCommit" -> managedCommitExceptionOpt.map(true).getOrElse(false),
+            "fromManagedCommit" -> managedCommitExceptionOpt.isDefined,
             "fromManagedCommitConflict" -> managedCommitExceptionOpt.map(_.conflict).getOrElse(""),
             "fromManagedCommitRetryable" ->
               managedCommitExceptionOpt.map(_.retryable).getOrElse("")))
@@ -1406,7 +1406,7 @@ trait OptimisticTransactionImpl extends TransactionalWrite
         data = Map(
           "exception" -> Utils.exceptionString(ex),
           "operation" -> op.name,
-          "fromManagedCommit" -> managedCommitExceptionOpt.map(true).getOrElse(false),
+          "fromManagedCommit" -> managedCommitExceptionOpt.isDefined,
           "fromManagedCommitConflict" -> managedCommitExceptionOpt.map(_.conflict).getOrElse(""),
           "fromManagedCommitRetryable" ->
             managedCommitExceptionOpt.map(_.retryable).getOrElse("")))