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