Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.11.1, 1.11.2, 1.12.0
Description
When writing Flink tests, I could reduce the latency of my 'waitForDone' calls by writing my own looping retry-sleep logic than rely on `TableResult.getJobClient().get().getJobExecutionResult(...)`. This is because `MiniCluster` uses RpcGatewayRetriever which has a fixed 20ms retry.
For a complex test, this can save 50ms-100ms per test run.
An easy fix is to change this to an retry with exponential backoff. This reduces the impact
Attachments
Issue Links
- incorporates
-
FLINK-19772 Add utility for retrying async operations with exponential timeout
- Closed
- links to