Re: ctx.timestamp() returning null when using Processing Time

2019-11-06 Thread Komal Mariam
mal Mariam > *Date: *Wednesday, November 6, 2019 at 6:19 PM > *To: *user > *Subject: *ctx.timestamp() returning null when using Processing Time > > > > Dear all, > > > > I want to clear some of my variables in KeyedBroadcastProcessFunction after > a cert

Re: ctx.timestamp() returning null when using Processing Time

2019-11-06 Thread Yun Tang
: ctx.timestamp() returning null when using Processing Time Dear all, I want to clear some of my variables in KeyedBroadcastProcessFunction after a certain time. I implemented the onTimer() function but even though I am using ProcessingTime like so: env.setStreamTimeCharacteristic

ctx.timestamp() returning null when using Processing Time

2019-11-06 Thread Komal Mariam
Dear all, I want to clear some of my variables in KeyedBroadcastProcessFunction after a certain time. I implemented the onTimer() function but even though I am using ProcessingTime like so: env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime), I am getting null when ctx.timestamp() i