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

Posted by Puneet Kinra-2 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-tp25361p25381.html

I checked the same the function is getting exited when i am calling ctx.getTimeservice () function.

On Mon, Jan 7, 2019 at 10:27 PM Timo Walther <[hidden email]> wrote:

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

}

}

--

--

--