org.apache.spark.sql.AnalysisException

Queries with streaming sources must be executed with writeStream.start();

Samebug tips0

There are no available Samebug tips for this exception. If you know how to solve this issue, help other users by writing a short tip.

Don't give up yet. Paste your full stack trace to get a solution.

Solutions on the web31

  • Queries with streaming sources must be executed with writeStream.start();; kafka
  • Queries with streaming sources must be executed with writeStream.start();
  • Queries with streaming sources must be executed with writeStream.start();; FileSource[src/test/data]
  • Stack trace

    • org.apache.spark.sql.AnalysisException: Queries with streaming sources must be executed with writeStream.start(); at org.apache.spark.sql.catalyst.analysis.UnsupportedOperationChecker$.org$apache$spark$sql$catalyst$analysis$UnsupportedOperationChecker$$throwError(UnsupportedOperationChecker.scala:173) at org.apache.spark.sql.catalyst.analysis.UnsupportedOperationChecker$$anonfun$checkForBatch$1.apply(UnsupportedOperationChecker.scala:33) at org.apache.spark.sql.catalyst.analysis.UnsupportedOperationChecker$$anonfun$checkForBatch$1.apply(UnsupportedOperationChecker.scala:31) at org.apache.spark.sql.catalyst.trees.TreeNode.foreachUp(TreeNode.scala:126) at org.apache.spark.sql.catalyst.trees.TreeNode$$anonfun$foreachUp$1.apply(TreeNode.scala:125) at org.apache.spark.sql.catalyst.trees.TreeNode$$anonfun$foreachUp$1.apply(TreeNode.scala:125) at scala.collection.immutable.List.foreach(List.scala:381)

    Write tip

    You have a different solution? A short tip here would help you and many other users who saw this issue last week.

    Users with the same issue

    Unknown user
    Once, 3 weeks ago
    Once, 4 months ago
    Unknown user
    Once, 11 months ago
    Unknown user
    Once, 2 weeks ago
    Unknown user
    Once, 2 weeks ago
    1 more bugmates