You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Timo Walther (Jira)" <ji...@apache.org> on 2022/01/03 15:43:00 UTC
[jira] [Reopened] (FLINK-25085) Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped
[ https://issues.apache.org/jira/browse/FLINK-25085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Timo Walther reopened FLINK-25085:
----------------------------------
I reverted the following commits to stabilize the master in private Azure builds again:
{code}
commit 612fa110ad51138f54afcb17867a8f4cd04eb695 (HEAD -> master, upstream/master)
Author: Timo Walther <tw...@apache.org>
Date: Mon Jan 3 16:37:40 2022 +0100
Revert "[FLINK-25426] Disable UnalignedCheckpointRescaleITCase because it fails regularly"
This reverts commit 276570e223a9b4ddb3939101b0fe3ff995ac46c5.
commit d6f12989eda1ceb501ddd831a9c1b3098f6a1031
Author: Timo Walther <tw...@apache.org>
Date: Mon Jan 3 16:37:28 2022 +0100
Revert "[FLINK-25427] Disable SavepointITCase.testTriggerSavepointAndResumeWithNoClaim because it is unstable"
This reverts commit fe3dfbca7ac8bada810726f1568e69fea855b039.
commit be75c0d82613726a7f508824730bbf2c9f6e8625
Author: Timo Walther <tw...@apache.org>
Date: Mon Jan 3 16:37:12 2022 +0100
Revert "[FLINK-25085][runtime] Add a scheduled thread pool in MainThreadExecutor and close it when the endpoint is stopped"
This reverts commit 5580cd6283eec0b977e1c5351fd3cdec2956510a.
{code}
> Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped
> ---------------------------------------------------------------------------------
>
> Key: FLINK-25085
> URL: https://issues.apache.org/jira/browse/FLINK-25085
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Affects Versions: 1.14.0, 1.12.5, 1.13.3
> Reporter: Shammon
> Assignee: Shammon
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.15.0
>
>
> Add a dedicated thread pool in Endpoint to schedule tasks that have a long delay such as PhysicalSlotRequestBulkCheckerImpl, heatbeat checker and some other timeout checker in JM/TM/RM. Job should shut down the thread pool and all the pending tasks will be removed when it terminates.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)