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: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org