Hi,

I am trying streaming with Zeppelin using the example given here: zepl.com
<https://www.zepl.com/viewer/notebooks/aHR0cHM6Ly9yYXcuZ2l0aHVidXNlcmNvbnRlbnQuY29tL2hhZml6dXItcmFobWFuL2NjcC1jaGFsbGVuZ2UxL21hc3Rlci96ZXBwZWxpbi9ub3RlYm9vay8yQVdLWFhKTVgvbm90ZS5qc29u>
But not able to get it to work.
I have configured Spark interpreter with a master (spark://dk1:7077).

a) The first time it ran, the paragraph was in running state but it wasn't
displaying any output (sent using nc command).

Upon restarting it started giving error:
java.lang.IllegalStateException: Only one StreamingContext may be started
in this JVM. Currently running StreamingContext was started
atorg.apache.spark.streaming.StreamingContext.start(StreamingContext.scala:569)
I realized that I only have ssc.start() and there is no call to stop(). So
in another paragraph I tried calling ssc.stop() before re-running my main
paragraph but it is still not helping.

My question is, what is the right way to start/stop streaming app so that
we can run it multiple times back to back?
Is my expectation that I should be seeing output in the same window correct?

Pls let me know if any more info is needed.

-Thanks
Nikhil

Reply via email to