Hi guys, I'm curious that how does BEAM translate its AccumulationMode such as DISCARDING_FIRED_PANES and ACCUMULATING_FIRED_PANES to Flink Runner implementation. Since I don't find directly respective concept in Flink world it puzzles me a lot.
Best, tison.
