Re: onTimer function is not getting executed and job is marked as finished.

Posted by Hequn Cheng on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/onTimer-function-is-not-getting-executed-and-job-is-marked-as-finished-tp25361p25367.html

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 <[hidden email]> 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..");

}

}

--