You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by gu...@apache.org on 2021/12/22 08:30:33 UTC

[flink] branch master updated (74ed032 -> 5580cd6)

This is an automated email from the ASF dual-hosted git repository.

guoyangze pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 74ed032  [FLINK-25365][python] Remove remaining references to planner from Python
     add 5580cd6  [FLINK-25085][runtime] Add a scheduled thread pool in MainThreadExecutor and close it when the endpoint is stopped

No new revisions were added by this update.

Summary of changes:
 .../concurrent/ComponentMainThreadExecutor.java    |  9 ++-
 .../concurrent/ThrowingScheduledFuture.java        | 25 +++----
 .../flink/runtime/rpc/FencedRpcEndpoint.java       | 25 ++++++-
 .../org/apache/flink/runtime/rpc/RpcEndpoint.java  | 81 +++++++++++++++++-----
 .../ComponentMainThreadExecutorServiceAdapter.java |  3 +
 ...nuallyTriggeredComponentMainThreadExecutor.java |  3 +
 .../apache/flink/runtime/rpc/RpcEndpointTest.java  | 66 +++++++++++++++---
 7 files changed, 167 insertions(+), 45 deletions(-)
 copy flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/CompletedScheduledFuture.java => flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/concurrent/ThrowingScheduledFuture.java (77%)