Github user skambha commented on a diff in the pull request:
https://github.com/apache/spark/pull/17185#discussion_r207717569
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/unresolved.scala
---
@@ -316,8 +345,8 @@ case class UnresolvedRegex(regexPattern: String, table:
Option[String], caseSens
// If there is no table specified, use all input attributes that
match expr
case None => input.output.filter(_.name.matches(pattern))
// If there is a table, pick out attributes that are part of this
table that match expr
- case Some(t) => input.output.filter(_.qualifier.exists(resolver(_,
t)))
- .filter(_.name.matches(pattern))
+ case Some(t) => input.output.filter(a => resolver(a.qualifier.last,
t)).
--- End diff --
Sure. Will add a defensive check.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
