[ https://issues.apache.org/jira/browse/FLINK-4658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15510421#comment-15510421 ]
ASF GitHub Bot commented on FLINK-4658: --------------------------------------- GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2531 [FLINK-4658] [rpc] Allow RpcService to execute Runnables and Callables in its executor The PR is based on #2530. The newly introduced methods are `void RpcService.execute(Runnable)` and `Future<T> RpcService.execute(Callable<T>)`. Both methods allow to run code in the `Executor` of the `RpcService`. You can merge this pull request into a Git repository by running: $ git pull https://github.com/tillrohrmann/flink extendRpcService Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/2531.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2531 ---- commit cc7cdd75d23f2d4d201c0458f4543be1bc7e09f0 Author: Till Rohrmann <trohrm...@apache.org> Date: 2016-09-21T15:26:21Z [FLINK-4656] [rpc] Port the existing code to Flink's own future abstraction commit 2af2ada199e9473f571b050bd2a2752e06236efb Author: Till Rohrmann <trohrm...@apache.org> Date: 2016-09-21T16:16:27Z [FLINK-4658] [rpc] Allow RpcService to execute Runnables and Callables in its executor ---- > Allow RpcService to execute Callables in the RpcService executor > ---------------------------------------------------------------- > > Key: FLINK-4658 > URL: https://issues.apache.org/jira/browse/FLINK-4658 > Project: Flink > Issue Type: Sub-task > Components: Distributed Coordination > Reporter: Till Rohrmann > Assignee: Till Rohrmann > > In order to execute operations outside of the main executor thread, it would > be convenient to add a {{execute(Callable)}} method to the {{RpcService}}. > The {{execute}} method runs the given {{Callable}}/{{Runnable}} in its > {{ExecutionContext}} and, thus, outside of the main thread. -- This message was sent by Atlassian JIRA (v6.3.4#6332)