Just a guess, but doesn't the `.apply(0)' at the end of each of your print
statements take just the first one of the returned list?
On Wed, Sep 7, 2016 at 12:36 AM Ashok Kumar
wrote:
> Any help on this warmly appreciated.
>
>
> On Tuesday, 6 September 2016, 21:31,
Any help on this warmly appreciated.
On Tuesday, 6 September 2016, 21:31, Ashok Kumar
wrote:
Hello Gurus,
I am creating some figures and feed them into Kafka and then spark streaming.
It works OK but I have the following issue.
For now as a test I sent 5
Hello Gurus,
I am creating some figures and feed them into Kafka and then spark streaming.
It works OK but I have the following issue.
For now as a test I sent 5 prices in each batch interval. In the loop code this
is what is hapening
dstream.foreachRDD { rdd => val x= rdd.count
i