I have built a ML pipeline model on a static twitter data for sentiment analysis. When I use the model on a structured stream, it always throws "Queries with streaming sources must be executed with writeStream.start()". This particular model doesn't contain any documented "unsupported" operations. It only calls the transform() method of the stages. Anyone have encountered the issue? if the model doesn't contain HashingTFModel/IDFModel, it works fine, but then I can not create feature vectors from the tweet.
Thanks, Davis -- Sent from: http://apache-spark-developers-list.1001551.n3.nabble.com/ --------------------------------------------------------------------- To unsubscribe e-mail: dev-unsubscr...@spark.apache.org
