Re: Re: How can i just implement a crontab function using flink?

Posted by on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/How-many-task-managers-to-launch-for-a-job-tp27983p28247.html

I  tried。 But the  MyProcessWindowFunction still not tigged when there's no event in the window

Any insight on this?

source.assignTimestampsAndWatermarks(new AssignerWithPeriodicWatermarks<Map>() {
    @Override
    public Watermark getCurrentWatermark() {
        return new Watermark(System.currentTimeMillis() - 10000);
    }

    @Override
    public long extractTimestamp(Map map, long l) {
        return System.currentTimeMillis();
    }
}).windowAll(TumblingEventTimeWindows.of(Time.seconds(10))).process(new MyProcessWindowFunction());

---

[hidden email]

 

From: [hidden email]

Date: 2019-05-24 17:02

To: [hidden email]

CC: [hidden email]

Subject: Re: How can i just implement a crontab function using flink?

There is concept of periodic watermarker , you can use that

if you are working on eventtime.

On Fri, May 24, 2019 at 1:51 PM [hidden email] <[hidden email]> wrote:

I want to do something every one minute.

Using TumblingWindow, the function will not be triigged if there's no message received during this minute. But  i still need to execute the funtion.

How can i implement it ? 

---

[hidden email]

 

--