Hi,depending on which version of Flink you're using the answer changes. If
you use Flink 1.1 AggregatingProcessingTimeWindowOperator should be
responsible for executing that. In Flink 1.2 it should be WindowOperator.
For a quick overview of how scheduling works in Flink you could look at
this:
htt
Hi Flink Dev,
I’m new to Flink and have a few questions below:
1. I’m trying to understand Flink runtime on the server side, and couldn’t
figure out where the code which execute the window function sum below. I wanted
to put a break point but got lost in the code base. Could someone shed a ligh
