Unfortunately zeromq 4.0.1 is not supported. https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/streaming/examples/ZeroMQWordCount.scala#L63Says about the version. You will need that version of zeromq to see it work. Basically I have seen it working nicely with zeromq 2.2.0 and if you have jzmq libraries installed performance is much better.
Prashant Sharma On Tue, Apr 29, 2014 at 12:29 PM, Francis.Hu <francis...@reachjunction.com>wrote: > Hi, all > > > > I installed spark-0.9.1 and zeromq 4.0.1 , and then run below example: > > > > ./bin/run-example > org.apache.spark.streaming.examples.SimpleZeroMQPublisher *tcp*:// > 127.0.1.1:1234 foo.bar` > > ./bin/run-example org.apache.spark.streaming.examples.ZeroMQWordCount > local[2] *tcp*://127.0.1.1:1234 *foo*` > > > > No any message was received in ZeroMQWordCount side. > > > > Does anyone know what the issue is ? > > > > > > Thanks, > > Francis > > >
