Skip to content

Commit 3422275

Browse files
committed
spark4.0 parse
1 parent c52e93e commit 3422275

File tree

1 file changed

+3
-1
lines changed
  • paimon-spark/paimon-spark-4.0/src/test/scala/org/apache/spark/sql/catalyst/parser

1 file changed

+3
-1
lines changed

paimon-spark/paimon-spark-4.0/src/main/scala/org/apache/spark/sql/catalyst/parser/parsers.scala renamed to paimon-spark/paimon-spark-4.0/src/test/scala/org/apache/spark/sql/catalyst/parser/parsers.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -252,7 +252,9 @@ class ParseException private (
252252
queryContext.foreach(ctx => builder ++= ctx.summary())
253253
} else {
254254
start match {
255-
case Origin(Some(l), Some(p), _, _, _, _, _, _, _) =>
255+
case a: Origin if a.line.isDefined && a.startPosition.isDefined =>
256+
val l = a.line.get
257+
val p = a.startPosition.get
256258
builder ++= s" (line $l, pos $p)\n"
257259
command.foreach {
258260
cmd =>

0 commit comments

Comments
 (0)