ok it's working! Thanks. Just out of curiosity, why is the println of keyBy
printing twice?
On Mon, 31 Jan 2022 at 17:22, John Smith wrote:
> Oh ok. I was reading here:
> https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/learn-flink/streaming_analytics/#latency-vs-completeness
> an
Oh ok. I was reading here:
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/learn-flink/streaming_analytics/#latency-vs-completeness
and Idid a cut and paste lol
Ok let you know.
On Mon, 31 Jan 2022 at 17:18, Dario Heinisch
wrote:
> Then you should be using a process based time w
Then you should be using a process based time window, in your case:
TumblingProcessingTimeWindows
See
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/windows/
for more info
On 31.01.22 23:13, John Smith wrote:
Hi Dario, I don't care about event time I just
Hi Dario, I don't care about event time I just want to do tumbling window
over the "processing time" I.e: count whatever I have in the last 5 minutes.
On Mon, 31 Jan 2022 at 17:09, Dario Heinisch
wrote:
> Hi John
>
> This is because you are using event time (TumblingEventTimeWinodws) but
> you d
Hi John
This is because you are using event time (TumblingEventTimeWinodws) but
you do not have a event time watermark strategy.
It is also why I opened:
https://issues.apache.org/jira/browse/FLINK-24623 because I feel like
Flink should be throwing an exception in that case
on startup.
Take
Hi I have the following job... I'm expecting the System.out
.println(key.toString()); to at least print, but nothing prints.
- .flatMap: Fires prints my debug message once as expected.
- .keyBy: Also fires, but prints my debug message twice.
- .apply: Doesn't seem to fire. The debug statement do
