cloud-fan commented on a change in pull request #29349: URL: https://github.com/apache/spark/pull/29349#discussion_r466840097
########## File path: sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/optimizer/FilterPushdownSuite.scala ########## @@ -1149,75 +1149,60 @@ class FilterPushdownSuite extends PlanTest { comparePlans(Optimize.execute(originalQuery.analyze), correctAnswer) } - test("join condition pushdown: deterministic and non-deterministic") { - val x = testRelation.subquery('x) - val y = testRelation.subquery('y) - - // Verify that all conditions except the watermark touching condition are pushed down - // by the optimizer and others are not. - val originalQuery = x.join(y, condition = Some("x.a".attr === 5 && "y.a".attr === 5 && - "x.a".attr === Rand(10) && "y.b".attr === 5)) - val correctAnswer = - x.where("x.a".attr === 5).join(y.where("y.a".attr === 5 && "y.b".attr === 5), - condition = Some("x.a".attr === Rand(10))) - - // CheckAnalysis will ensure nondeterministic expressions not appear in join condition. - // TODO support nondeterministic expressions in join condition. - comparePlans(Optimize.execute(originalQuery.analyze), correctAnswer.analyze, - checkAnalysis = false) - } - test("watermark pushdown: no pushdown on watermark attribute #1") { val interval = new CalendarInterval(2, 2, 2000L) + val relation = LocalRelation(attrA, 'b.timestamp, attrC) // Verify that all conditions except the watermark touching condition are pushed down // by the optimizer and others are not. - val originalQuery = EventTimeWatermark('b, interval, testRelation) - .where('a === 5 && 'b === 10 && 'c === 5) + val originalQuery = EventTimeWatermark('b, interval, relation) + .where('a === 5 && 'b === new java.sql.Timestamp(0) && 'c === 5) Review comment: watermark column must be timestamp. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org