Hi Akhil Das, Thank you for your reply.
It is very similar to my problem, I will focus on it.
Thanks
Best Regards
At 2015-04-28 18:08:32,"Akhil Das" wrote:
>There's a similar issue reported over here
>https://issues.apache.org/jira/browse/SPARK-6847
>
>Thanks
>Best Regards
>
>On Tue, Apr 28, 2015
There's a similar issue reported over here
https://issues.apache.org/jira/browse/SPARK-6847
Thanks
Best Regards
On Tue, Apr 28, 2015 at 7:35 AM, wyphao.2007 wrote:
> Hi everyone, I am using val messages =
> KafkaUtils.createDirectStream[String, String, StringDecoder,
> StringDecoder](ssc, kafk
Hi everyone, I am using val messages = KafkaUtils.createDirectStream[String,
String, StringDecoder, StringDecoder](ssc, kafkaParams, topicsSet) to read data
from kafka(1k/second), and store the data in windows,the code snippets as
follow:val windowedStreamChannel =
streamChannel.combin
