I have an issue with tumbling windows running in parallel. I run a Job on a set of CSV files.
When the parallelism is set to 1. I get the proper results. While it runs in parallel. I get no output. Is it due to the fact the parallel streams take the MAX(watermark) from all the parallel sources. And only one of the streams advances the watermark ? It seems wrong that the result is not deterministic and depends on the parallel level. What am I doing wrong ?
