Re: Spark Streaming union expected behaviour?

2014-09-15 Thread Varad Joshi
I am seeing the same exact behavior. Shrikar, did you get any response to your post? Varad -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-union-expected-behaviour-tp7206p14284.html Sent from the Apache Spark User List mailing list archive

Reading from multiple sockets

2014-09-11 Thread Varad Joshi
Still fairly new to Spark so please bear with me. I am trying to write a streaming app that has multiple workers that read from sockets and process the data. Here is a very simplified version of what I am trying to do: val carStreamSeq = (1 to 2).map( _ = ssc.socketTextStream(host, port)