Github user jose-torres commented on the issue: https://github.com/apache/spark/pull/21136 LGTM. TypedFilter and Filter share the FilterExec execution node, so this should just work. Ideally we would add a test to ContinuousSuite to ensure that TypedFilter does execute properly, but I understand this may not be sustainable. Eventually we'll just remove this whitelist and find some way to broadly execute all the streaming tests for continuous processing.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org