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