working as expected now.
Thanks for the help!
Chris
From: Chesnay Schepler
Date: Wednesday, May 12, 2021 at 5:24 AM
To: "Slotterback, Chris" ,
"user@flink.apache.org"
Subject: Re: [EXTERNAL] Re: sideOutputLateData not propagating late reports
once window expires
Ah, sorry for t
ate: *Tuesday, May 11, 2021 at 6:09 AM
*To: *"Slotterback, Chris" ,
"user@flink.apache.org"
*Subject: *[EXTERNAL] Re: sideOutputLateData not propagating late
reports once window expires
Please try this:
val windowedStream = stream
.keyBy(…)
.window(TumblingEventTimeWindow
bject: [EXTERNAL] Re: sideOutputLateData not propagating late reports once
window expires
Please try this:
val windowedStream = stream
.keyBy(…)
.window(TumblingEventTimeWindows.of(…))
.allowedLateness(…)
.sideOutputLateData(lateTag)
.trigger(new myTrigger)
val lateStream =
windowed
