[
https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916607#comment-16916607
]
Xiaogang Shi commented on FLINK-13848:
--------------------------------------
1. Yes. If the task message is already sent to the actor's mailbox, it's very
difficult to prohibit it from being executed by the actor. Using a boolean flag
which can be accessed by returned ScheduledFuture may be a solution, but that
makes the cancellation very complicated.
2. Most rpc endpoints are already equipped with {{ScheduledExecutorService}}
which can be used to achieve periodical triggering. If you take a look at the
implementation, {{ScheduledExecutorService}} implements periodically scheduling
by scheduling next triggering after the completion of current triggering.
> 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)
