Github user dongjoon-hyun commented on a diff in the pull request:
https://github.com/apache/spark/pull/19336#discussion_r141215037
--- Diff:
sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/UnsupportedOperationsSuite.scala
---
@@ -516,6 +516,14 @@ class UnsupportedOperationsSuite extends SparkFunSuite
{
testOutputMode(Update, shouldSupportAggregation = true,
shouldSupportNonAggregation = true)
testOutputMode(Complete, shouldSupportAggregation = true,
shouldSupportNonAggregation = false)
+ // Unsupported expressions in streaming plan
+ assertNotSupportedInStreamingPlan(
+ "MonotonicallyIncreasingID",
+ streamRelation.select($"a", MonotonicallyIncreasingID()),
--- End diff --
nit. We can remove `$"a"` here.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
