Fix unwrappedCondition

apache · Jul 1, 2022 · c6f80a4 · c6f80a4
1 parent a8391bb
commit c6f80a4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...asource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieAnalysis.scala b/...asource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieAnalysis.scala
@@ -414,7 +414,7 @@ case class HoodieResolveReferences(sparkSession: SparkSession) extends Rule[Logi
     case DeleteFromTable(table, condition)
       if sparkAdapter.isHoodieTable(table, sparkSession) && table.resolved =>
       val unwrappedCondition: Expression = condition match {
-        case option: Option[Expression] => option.get
+        case option: Option[Expression] => option.getOrElse(None)
         case expr: Expression => expr
         case _ => throw new IllegalArgumentException(s"condition has to be either Option[Expression] or Expression")
       }