Re: Flink not processing the records

2021-08-12 Thread JING ZHANG
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 >

Re: Flink not processing the records

2021-08-12 Thread Megha Gandhi
> 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 >