Hi Puneet,
maybe you can show or explain us a bit more about your pipeline. From
what I see your ProcessFunction looks correct. Are you sure the
registering takes place?
Regards,
Timo
Am 07.01.19 um 14:15 schrieb Puneet Kinra:
Hi Hequn
Its a streaming job .
On Mon, Jan 7, 2019 at 5:51 PM Hequn Cheng <chenghe...@gmail.com
<mailto:chenghe...@gmail.com>> 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
<puneet.ki...@customercentria.com
<mailto:puneet.ki...@customercentria.com>> 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 :
puneet.ki...@customercentria.com
<mailto:puneet.ki...@customercentria.com>*
*e-mail :puneet.ki...@customercentria.com
<mailto:puneet.ki...@customercentria.com>*
--
*Cheers *
*
*
*Puneet Kinra*
*
*
*Mobile:+918800167808 | Skype : puneet.ki...@customercentria.com
<mailto:puneet.ki...@customercentria.com>*
*e-mail :puneet.ki...@customercentria.com
<mailto:puneet.ki...@customercentria.com>*
