create a Jira with a description of the problem?
It would be great, if you could provide a reproducible example with a data
generator source.
Thank you,
Fabian
Am Di., 1. Okt. 2019 um 11:18 Uhr schrieb Oliwer Kostera
mailto:o.kost...@adbglobal.com>>:
Hi,
I'm no sure what
Qiu wrote:
Hi Oliwer,
From the description, Seems the state didn't be cleared, maybe you could check
how many {{windowState.clear()}} was triggered in
{{WindowOperator#processElement}}, and try to figure it out why the state did
not be cleared.
Best,
Congxian
Oliwer Kostera mailto:o.kost..
Hi all,
I'm using ProcessWindowFunction in a keyed stream with the following definition:
final SingleOutputStreamOperator processWindowFunctionStream =
keyedStream.window(ProcessingTimeSessionWindows.withGap(Time.milliseconds(100)))
.process(new CustomProcessWindowFunction(
