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
Helloļ¼
I was unable to do event time window aggregation with Kafka source, but had no
problem with "fromElement" source. The code is attached as follow. The code has
two data sources, named "streamSource" and "kafkaSource" respectively. The
program works well with "streamSource", but not wit
