RE: Issue with onTimer method of KeyedProcessFunction

2021-06-09 Thread V N, Suchithra (Nokia - IN/Bangalore)
= aggrRecord.get(); // Always get null value. Thanks, Suchithra From: JING ZHANG Sent: Wednesday, June 9, 2021 2:20 PM To: V N, Suchithra (Nokia - IN/Bangalore) Cc: user@flink.apache.org; Jash, Shaswata (Nokia - IN/Bangalore) Subject: Re: Issue with onTimer method of KeyedProcessFunction Hi Suchithra

RE: Issue with onTimer method of KeyedProcessFunction

2021-06-09 Thread V N, Suchithra (Nokia - IN/Bangalore)
= aggrRecord.get(); // Always get null value. Thanks, Suchithra From: JING ZHANG Sent: Wednesday, June 9, 2021 2:20 PM To: V N, Suchithra (Nokia - IN/Bangalore) Cc: user@flink.apache.org; Jash, Shaswata (Nokia - IN/Bangalore) Subject: Re: Issue with onTimer method of KeyedProcessFunction Hi Suchithra

Re: Issue with onTimer method of KeyedProcessFunction

2021-06-09 Thread JING ZHANG
Hi Suchithra, Would you please provide more information in detail or paste the main code? Best regards, JING ZHANG V N, Suchithra (Nokia - IN/Bangalore) 于2021年6月9日周三 下午3:42写道: > Hello, > > > > We are using apache flink 1.7 and now trying to upgrade to flink 1.12.3 > version. After upgrading to

Issue with onTimer method of KeyedProcessFunction

2021-06-09 Thread V N, Suchithra (Nokia - IN/Bangalore)
Hello, We are using apache flink 1.7 and now trying to upgrade to flink 1.12.3 version. After upgrading to 1.12.3 version, the onTimer method of KeyedProcessFunction is not behaving correctly, the value of ReducingState and ValueState always return null. Could you please help in debugging