Github user mgaido91 commented on a diff in the pull request:
https://github.com/apache/spark/pull/19494#discussion_r145252308
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/columnar/InMemoryColumnarQuerySuite.scala
---
@@ -429,4 +429,19 @@ class InMemoryColumnarQuerySuite extends QueryTest
with SharedSQLContext {
checkAnswer(agg_without_cache, agg_with_cache)
}
}
+
+ test("SPARK-22249: IN should work also with cached DataFrame") {
--- End diff --
do you mean this test case is not enough and I should add a test case to
check the proper behavior of the optimizer after the change?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
