Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21745#discussion_r201621224
--- Diff:
sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/plans/LogicalPlanSuite.scala
---
@@ -119,4 +119,16 @@ class LogicalPlanSuite extends SparkFunSuite {
OneRowRelation())
assert(result.sameResult(expected))
}
+
+ test("Logical plan with missing inputs should be unresolved") {
+ // Normally we won't add a missing resolved reference into a logical
plan,
+ // but a valid query like `df.select(df("name")).filter(df("id") ===
0)` can make a query
+ // like this.
+ val relation = LocalRelation(AttributeReference("a", IntegerType,
nullable = true)())
+ val plan = Project(Stream(AttributeReference("b", IntegerType,
nullable = true)()), relation)
--- End diff --
Why `Stream`?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
