Hi!
I have a problem that I cannot really track down. I'll try to describe
the issue.
My streaming flink program computes something. At the end I'm doing the
follwing on my DataStream ds
ds.window(2, TimeUnit.SECONDS)
.groupBy(/*custom KeySelector converting input to a String representation*/)
.mapWindow(/*TypeConversion*/)
.flatten()
Then the result is written to a Kafka topic.
The purpose of this is output deduplication within a 2 seconds window...
Without the above the program works fine. But with the above I don't get
any output and no error appears in the log. The program keeps running.
Am I doing something wrong?
I would be happy for help!
Cheers, Rico.
