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
Please try this:
val windowedStream = stream
.keyBy(…)
.window(TumblingEventTimeWindows./of/(…))
.allowedLateness(…)
.sideOutputLateData(lateTag)
.trigger(new myTrigger)
val lateStream = windowedStream.getSideOutput(lateTag); val
aggregatedStream = windowedStream.aggregate(new
VSGB
Hey Flink Users,
I am having some issues with getting sideOutputLateData to properly function
with late event time reports. I have the following code that, per my
understanding, should be allowing reports that fall after the window has
triggered and beyond allowed lateness to pass through to th
