This is an automated email from the ASF dual-hosted git repository. alsuliman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/asterixdb.git
commit 244c3c5e8c12f5ab7699609fdc47ffad6d2675b0 Author: Michael Blow <[email protected]> AuthorDate: Tue Apr 6 12:39:30 2021 -0400 [NO ISSUE][HYR][UTIL] Abort retries on expired span no retry delay Change-Id: I2f56cc23c5a869e76241f1ac303cf57a14714182 Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/10923 Reviewed-by: Michael Blow <[email protected]> Reviewed-by: Ian Maxon <[email protected]> Reviewed-by: Hussain Towaileb <[email protected]> Tested-by: Michael Blow <[email protected]> --- .../src/main/java/org/apache/hyracks/api/util/InvokeUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/util/InvokeUtil.java b/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/util/InvokeUtil.java index 6ecb677..0b1c5a6 100644 --- a/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/util/InvokeUtil.java +++ b/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/util/InvokeUtil.java @@ -278,7 +278,7 @@ public class InvokeUtil { failure = th; try { long delayMs = delay.calculate(attempt); - if (!policy.retry(th) || span.remaining(TimeUnit.MILLISECONDS) < delayMs) { + if (!policy.retry(th) || span.elapsed() || span.remaining(TimeUnit.MILLISECONDS) < delayMs) { onFailure.attemptFailed(action, attempt, true, span, failure); throw HyracksDataException.create(failure); } else {
