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

Posted to commits@flink.apache.org by tw...@apache.org on 2022/01/03 15:40:16 UTC

[flink] branch master updated (6681a47 -> 612fa11)

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

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


    from 6681a47  [hotfix][docs] Remove duplicate dot in generating_watermarks.md
     add be75c0d  Revert "[FLINK-25085][runtime] Add a scheduled thread pool in MainThreadExecutor and close it when the endpoint is stopped"
     add d6f1298  Revert "[FLINK-25427] Disable SavepointITCase.testTriggerSavepointAndResumeWithNoClaim because it is unstable"
     add 612fa11  Revert "[FLINK-25426] Disable UnalignedCheckpointRescaleITCase because it fails regularly"

No new revisions were added by this update.

Summary of changes:
 .../concurrent/ComponentMainThreadExecutor.java    |  9 +--
 .../concurrent/ThrowingScheduledFuture.java        | 76 --------------------
 .../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 +++---------------
 .../flink/test/checkpointing/SavepointITCase.java  |  2 -
 .../UnalignedCheckpointRescaleITCase.java          |  2 -
 9 files changed, 31 insertions(+), 236 deletions(-)
 delete mode 100644 flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/concurrent/ThrowingScheduledFuture.java