Hi Averell, As Till pointed out, currently Flink doesn't provide such a flexible schedule strategy.
However, our team internally implemented a mechanism that allow user-define schedule plugin(flexible schedule strategy). It could fit your case by setting a timer on schedule start and trigger (1) after a fixed delay; or when (2) loaded, a execution event be sent to the schedule plugin then it schedules (1). This work is on going to contribute back to Flink master, you can follow this JIRA[1] for more information. We are glad if this work could help you. Best, tison. [1] https://issues.apache.org/jira/browse/FLINK-10240 Averell <lvhu...@gmail.com> 于2018年9月26日周三 下午3:46写道： > Hi Kostas, > > So that means my 2a will be broadcasted to all TMs? Is that possible to > partition that? As I'm using CoProcessFunction to join 1 with 2. > > Thanks and best regards, > Averell > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
