fix comment

apache · Apr 26, 2024 · efdfa01 · efdfa01
1 parent 6b540bd
commit efdfa01
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/...common/src/main/scala/org/apache/paimon/spark/commands/DeleteFromPaimonTableCommand.scala b/...common/src/main/scala/org/apache/paimon/spark/commands/DeleteFromPaimonTableCommand.scala
@@ -83,10 +83,7 @@ case class DeleteFromPaimonTableCommand(
       // 3) partition predicate can be visit by OnlyPartitionKeyEqualVisitor.
       val forceDeleteByRows =
         otherCondition.nonEmpty || partitionPredicate.isEmpty || !partitionPredicate.get.visit(
-          visitor) || (table.store().options().deleteForceProduceChangelog() && table
-          .store()
-          .options()
-          .changelogProducer() != CoreOptions.ChangelogProducer.NONE)
+          visitor) || table.store().options().deleteForceProduceChangelog()
 
       if (forceDeleteByRows) {
         val commitMessages = if (withPrimaryKeys) {