[
https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916429#comment-16916429
]
Biao Liu commented on FLINK-13848:
----------------------------------
Hi [~xiaogang.shi],
Thanks a lot for sharing valuable experience!
>From my understanding, the first choice is via Akka dispatcher/scheduler. We
>could also support period scheduling manually, however IMO reinventing the
>wheel is not the best option.
I'm very interested in the issues you have met. I have a couple of questions on
these issues.
1. "we can only cancel the scheduling of task messages in Akka, but fail to
cancel those task messages already sent".
I didn't get this. Do you mean you could not cancel the message which is
already scheduled?
2. "we decided to use a non-main-threaded ScheduledExecutorService together
with runAsync to achieve periodic triggering in main thread"
Is it necessary that involving another {{ScheduledExecutorService}}? Could it
be satisfied by scheduling next trigger when processing the 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)
