Hi Hequn Its a streaming job .
On Mon, Jan 7, 2019 at 5:51 PM Hequn Cheng <[email protected]> wrote: > Hi Puneet, > > The value of the registered timer should within startTime and endTime of > your job. For example, job starts at processing time t1 and stops at > processing time t2. You have to make sure t1< `parseLong + 5000` < t2. > > Best, Hequn > > On Mon, Jan 7, 2019 at 5:50 PM Puneet Kinra < > [email protected]> wrote: > >> Hi All >> >> Facing some issue with context to onTimer method in processfunction >> >> class TimerTest extends ProcessFunction<Tuple2<String,String>,String>{ >> >> /** >> * >> */ >> private static final long serialVersionUID = 1L; >> >> @Override >> public void processElement(Tuple2<String, String> arg0, >> ProcessFunction<Tuple2<String, String>, String>.Context ctx, >> Collector<String> arg2) throws Exception { >> // TODO Auto-generated method stub >> long parseLong = Long.parseLong(arg0.f1); >> TimerService timerService = ctx.timerService(); >> ctx.timerService().registerProcessingTimeTimer(parseLong + 5000); >> } >> >> @Override >> public void onTimer(long timestamp, ProcessFunction<Tuple2<String, >> String>, String>.OnTimerContext ctx, >> Collector<String> out) throws Exception { >> // TODO Auto-generated method stub >> super.onTimer(timestamp, ctx, out); >> System.out.println("Executing timmer"+timestamp); >> out.collect("Timer Testing.."); >> } >> } >> >> -- >> *Cheers * >> >> *Puneet Kinra* >> >> *Mobile:+918800167808 | Skype : [email protected] >> <[email protected]>* >> >> *e-mail :[email protected] >> <[email protected]>* >> >> >> -- *Cheers * *Puneet Kinra* *Mobile:+918800167808 | Skype : [email protected] <[email protected]>* *e-mail :[email protected] <[email protected]>*
