Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/18973#discussion_r138095165
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicLogicalOperators.scala
---
@@ -443,7 +444,8 @@ case class Range(
end: Long,
step: Long,
numSlices: Option[Int],
- output: Seq[Attribute])
+ output: Seq[Attribute],
+ override val isStreaming: Boolean)
--- End diff --
how can a `Range` have data from a streaming source?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
