diff --git a/core/src/main/scala/io/delta/tables/DeltaTableBuilder.scala b/core/src/main/scala/io/delta/tables/DeltaTableBuilder.scala index a858c5e3ce6..1d039c1f409 100644 --- a/core/src/main/scala/io/delta/tables/DeltaTableBuilder.scala +++ b/core/src/main/scala/io/delta/tables/DeltaTableBuilder.scala @@ -19,11 +19,7 @@ package io.delta.tables import scala.collection.mutable import org.apache.spark.sql.delta.{DeltaErrors, DeltaTableUtils} -<<<<<<< HEAD -======= import org.apache.spark.sql.delta.DeltaTableUtils.withActiveSession -import org.apache.spark.sql.delta.sources.DeltaSQLConf ->>>>>>> 91d25681b (set active session for commands) import io.delta.tables.execution._ import org.apache.spark.annotation._ diff --git a/core/src/main/scala/io/delta/tables/execution/DeltaTableOperations.scala b/core/src/main/scala/io/delta/tables/execution/DeltaTableOperations.scala index a105906c007..e1b8e6538ae 100644 --- a/core/src/main/scala/io/delta/tables/execution/DeltaTableOperations.scala +++ b/core/src/main/scala/io/delta/tables/execution/DeltaTableOperations.scala @@ -40,17 +40,10 @@ import org.apache.spark.sql.execution.datasources.v2.DataSourceV2Relation trait DeltaTableOperations extends AnalysisHelper { self: DeltaTable => protected def executeDelete(condition: Option[Expression]): Unit = improveUnsupportedOpError { -<<<<<<< HEAD - val delete = DeleteFromTable(self.toDF.queryExecution.analyzed, condition) - toDataset(sparkSession, delete) -======= withActiveSession(sparkSession) { - val delete = DeleteFromTable( - self.toDF.queryExecution.analyzed, - condition.getOrElse(Literal.TrueLiteral)) + val delete = DeleteFromTable(self.toDF.queryExecution.analyzed, condition) toDataset(sparkSession, delete) } ->>>>>>> 91d25681b (set active session for commands) } protected def executeHistory(