You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by al...@apache.org on 2021/04/07 12:48:03 UTC
[asterixdb] 22/25: [NO ISSUE][HYR][UTIL] Abort retries on expired
span no retry delay
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 <mb...@apache.org>
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 <mb...@apache.org>
Reviewed-by: Ian Maxon <im...@uci.edu>
Reviewed-by: Hussain Towaileb <hu...@gmail.com>
Tested-by: Michael Blow <mb...@apache.org>
---
.../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 {