You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/10/23 19:56:25 UTC
[flink] branch master updated (d4386e6 -> 59e73e0)

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

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


    from d4386e6  [FLINK-19640] Add an IT case for bounded execution
     add b3a9442  [FLINK-19721][runtime] Support exponential backoff retries in RpcGatewayRetriever
     add 59e73e0  [FLINK-19721] Let RpcGatewayRetrievers in DispatcherResourceManagerComponent use ExponentialBackoffRetryStrategy

No new revisions were added by this update.

Summary of changes:
 .../ExponentialBackoffRetryStrategy.java           | 65 +++++++++++++++++++
 .../runtime/concurrent/FixedRetryStrategy.java     | 59 +++++++++++++++++
 .../flink/runtime/concurrent/FutureUtils.java      | 63 ++++++++++++++----
 .../flink/runtime/concurrent/RetryStrategy.java    | 20 +++---
 ...tDispatcherResourceManagerComponentFactory.java |  9 ++-
 .../flink/runtime/minicluster/MiniCluster.java     |  8 +--
 .../retriever/impl/RpcGatewayRetriever.java        | 18 ++----
 .../ExponentialBackoffRetryStrategyTest.java       | 74 ++++++++++++++++++++++
 .../FixedRetryStrategyTest.java}                   | 35 +++++-----
 .../flink/runtime/concurrent/FutureUtilsTest.java  | 56 ++++++++++++++--
 .../retriever/impl/RpcGatewayRetrieverTest.java    |  4 +-
 11 files changed, 348 insertions(+), 63 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ExponentialBackoffRetryStrategy.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FixedRetryStrategy.java
 copy flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKind.java => flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/RetryStrategy.java (65%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ExponentialBackoffRetryStrategyTest.java
 copy flink-runtime/src/test/java/org/apache/flink/runtime/{rest/messages/VertexBackPressureLevelTest.java => concurrent/FixedRetryStrategyTest.java} (51%)