[ 
https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916614#comment-16916614
 ] 

Biao Liu commented on FLINK-13848:
----------------------------------

Thanks for feedback. [~xiaogang.shi]

1. We could get back to this topic after doing some testings myself. Thanks for 
explanation.

2. What I mean is that it seems that we could support periodic scheduling 
without involving any other {{ScheduledExecutorService}}. Just using delayed 
scheduling of {{MainThreadExecutor}}. Am I misunderstand your description of 
"use a non-main-threaded ScheduledExecutorService together with runAsync"? 

> 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)

Reply via email to