h worker-0] INFO
org.apache.spark.executor.Executor - Finished task 0.0 in stage 12.0 (TID
12). 2518 bytes result sent to driver
Does anyone have any ideas?
On Wed, Sep 7, 2016 at 7:30 PM, Kevin Tran wrote:
> Hi Everyone,
> Does anyone know why call() function being called *3 tim
Hi Everyone,
Does anyone know why call() function being called *3 times* for each
message arrive
JavaDStream message = messagesDStream.map(new
>> Function, String>() {
>
> @Override
>
> public String call(Tuple2 tuple2) {
>
> return tuple2._2();
>
> }
>
>
