question.
If I use create a 1 ms window using event time processing, is that supported when there are multiple task managers?
I am leveraging the map reduce algorithm and I am using a window to reduce and de-duplicate data. It works single node cluster, but when I run on a multi-node cluster, that operator never receives data.
TumblingEventTimeWindows.of(Time.milliseconds(1))