From e9a6816a5bc58fa3466994660a421ab6d83dc0d8 Mon Sep 17 00:00:00 2001 From: Sumeet Varma Date: Thu, 28 Mar 2024 14:56:49 -0700 Subject: [PATCH] Nit --- .../org/apache/spark/sql/delta/OptimisticTransaction.scala | 4 ++-- 1 file changed, 2 insertions(+), 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 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("")))