[
https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16918535#comment-16918535
]
Biao Liu commented on FLINK-13848:
----------------------------------
Hi [~till.rohrmann],
I just found this issue could not satisfy our requirement. In the discussion
on design doc, we want to avoid competition between different triggers. Our
target is making triggers processed one by one. {{"scheduleAtFixedDelay"}}
seems to be the way we want. The {{"scheduleAtFixedDelay"}} schedules
{{runnable}} one after the other. But here the {{runnable}} of triggering is
asynchronous. The {{runnable}} is finished does not mean the triggering is also
finished.
I think we have to go back to the original plan, doing the triggering manually
(triggering the next one when the future of prior trigger is done), not through
{{MainThreadExecutor#scheduleAtFixedDelay}}.
> Support “scheduleAtFixedRate/scheduleAtFixedDelay” in
> RpcEndpoint#MainThreadExecutor
> ------------------------------------------------------------------------------------
>
> Key: FLINK-13848
> URL: https://issues.apache.org/jira/browse/FLINK-13848
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Reporter: Biao Liu
> Priority: Major
> Fix For: 1.10.0
>
>
> Currently the methods “scheduleAtFixedRate/scheduleAtFixedDelay" of
> {{RpcEndpoint#MainThreadExecutor}} are not implemented. Because there was no
> requirement on them before.
> Now we are planning to implement these methods to support periodic checkpoint
> triggering.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
