Hi all, I found an issue about the windows slice of dstream. My code is :
ssc = new StreamingContext( conf, Seconds(1))
val content = ssc.socketTextStream('ip','port')
content.countByValueAndWindow( Seconds(2), Seconds(8)).foreach( println(xxxx))
The key is that slide is greater than windows.
I checked the output.The result from foreach( println(xxxx)) was wrong.
I found the stream was cut apart wrong.
Can I open a JIRA please?
thanks
Fei Shao
