] 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 <kevin...@gmail.com> wrote:
> Hi Everyone,
> Does anyone know why call() function bei
Hi Everyone,
Does anyone know why call() function being called *3 times* for each
message arrive
JavaDStream message = messagesDStream.map(new
>> Function<Tuple2<String, String>, String>() {
>
> @Override
>
> public String call(Tuple2<String, Strin
