Re:Re: Unable to do event time window aggregation with Kafka source

[wei_yuze]

Hi Yuxia, Thanks for your reply! I expected the program to do reduce by key. It 
should count the number of data having the same username field. The program 
threw no exception, but it did not produce the expected output. Best regards, 
Lucas