Hi,
Thanks to Ted Vu and Nilanjan. Stopping the streaming context
asynchronously did the trick!
Thanks
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Invocation-of-StreamingContext-stop-hangs-in-1-5-tp25402p25434.html
Sent from the Apache Spark User L
ngDeque.java:489)
at
java.util.concurrent.LinkedBlockingDeque.take(LinkedBlockingDeque.java:678)
at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:46)
Thanks,
Jiten
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Invocation-of-Stre