Well that is not going to be easy, simply because we depend on akka-zeromq for zeromq support. And since akka does not support the latest zeromq library yet, I doubt if there is something simple that can be done to support it.
Prashant Sharma On Tue, Apr 29, 2014 at 2:44 PM, Francis.Hu <francis...@reachjunction.com>wrote: > Thanks, Prashant Sharma > > > > > > It works right now after degrade zeromq from 4.0.1 to 2.2. > > Do you know the new release of spark whether it will upgrade zeromq ? > > Many of our programs are using zeromq 4.0.1, so if in next release ,spark > streaming can release with a newer zeromq that would be better for us. > > > > > > Francis. > > > > *发件人:* Prashant Sharma [mailto:scrapco...@gmail.com] > *发送时间:* Tuesday, April 29, 2014 15:53 > *收件人:* user@spark.apache.org > *主题:* Re: Issue during Spark streaming with ZeroMQ source > > > > 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 > > > > >
