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`
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 zer
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
ming 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