Re: Flink session window not progressing

2019-04-29 Thread Konstantin Knauf
Hi Henrik, yes, the output count of a sink (and the input count of sources) is always zero, because only Flink internal traffic is reflected in these metrics. There is a Jira issue to change this [1]. Cheers, Konstantin [1] https://issues.apache.org/jira/browse/FLINK-7286 On Mon, Apr 29, 201

Re: Flink session window not progressing

2019-04-29 Thread Henrik Feldt
Thinking more about this; it might just be me who is reacting to the sink having a zero rate of output. In fact, I have about two gigs of messages left in the queue until it's up to date, so I may just be running a slow calculation (because I've run a batch job to backfill to after stream). Per

Flink session window not progressing

2019-04-29 Thread Henrik Feldt
Hi guys, I'm going a PoC with Flink and I was wondering if you could help me. I've asked a question here https://stackoverflow.com/questions/55907954/flink-session-window-sink-timestamp-not-progressing with some images. However, in summary my question is this; why doesn't my session window pr