[HUDI-4799] improve analyzer exception tip when can not resolve expre…

…ssion
apache · Sep 7, 2022 · 5f385a1 · 5f385a1
1 parent dbb044b
commit 5f385a1
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
@@ -267,7 +267,7 @@ case class HoodieResolveReferences(sparkSession: SparkSession) extends Rule[Logi
     case mergeInto @ MergeIntoTable(target, source, mergeCondition, matchedActions, notMatchedActions)
       if sparkAdapter.isHoodieTable(target, sparkSession) && target.resolved =>
       val resolver = sparkSession.sessionState.conf.resolver
-      val resolvedSource = analyzer.execute(source)
+      val resolvedSource = analyzer.executeAndCheck(source, null)
 
       def isInsertOrUpdateStar(assignments: Seq[Assignment]): Boolean = {
         if (assignments.isEmpty) {