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 index 491900cb3d0..d25380ac3cd 100644 --- 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("")))