Github user lw-lin commented on the pull request:
https://github.com/apache/spark/pull/12521#issuecomment-214585357
Updates: thanks to [[SPARK-14473][SQL] Define analysis rules to catch
operations not supported in
streaming](https://github.com/apache/spark/commit/775cf17eaaae1a38efe47b282b1d6bbdb99bd759),
now we have friendly messages for most of the incorrect usages:
> Exception in thread "main" org.apache.spark.sql.AnalysisException:
Queries with streaming sources must be executed with write.startStream();
and
> Exception in thread "main" org.apache.spark.sql.AnalysisException:
Queries without streaming sources cannot be executed with write.startStream();
-
That leaves this patch capturing other incorrect usages such as calling
`.trigger()`/`.queryName()` on non-continuous queries, or calling
`bucketBy()`/`sortBy()` on continuous queries.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
