xiangyu feng created FLINK-33684:
------------------------------------
Summary: Improve the retry strategy in CollectResultFetcher
Key: FLINK-33684
URL: https://issues.apache.org/jira/browse/FLINK-33684
Project: Flink
Issue Type: Sub-task
Components: API / DataStream
Reporter: xiangyu feng
Currently CollectResultFetcher use a fixed retry interval.
{code:java}
private void sleepBeforeRetry() {
if (retryMillis <= 0) {
return;
}
try {
// TODO a more proper retry strategy?
Thread.sleep(retryMillis);
} catch (InterruptedException e) {
LOG.warn("Interrupted when sleeping before a retry", e);
}
} {code}
This can be improved with a WaitStrategy.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
