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