Hi Megha,
Event window would be triggered after the watermark passed the end of
window. Would you please check the watermark value on the Flink UI.
Best,
JING ZHANG
Megha Gandhi 于2021年8月13日周五 上午2:33写道:
>
>
> On Aug 12, 2021, at 11:31 AM, Megha Gandhi wrote:
>
> Hi
> This is my flink app code
>
> On Aug 12, 2021, at 11:31 AM, Megha Gandhi wrote:
>
> Hi
> This is my flink app code
> DataStream input = createSourceFromStaticConfig(env);
> // Map it to a json
> ObjectMapper jsonParser = new ObjectMapper();
> DataStream> inputStream = input.map(value -> {
> // Parse the JSON
>