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