Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
xuyu committed Dec 10, 2024
1 parent 38b13c7 commit ae475ef
Showing 1 changed file with 6 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -750,7 +750,7 @@ private int tryCommit(
}

retryResult = (RetryResult) result;
retryCount++;


if ((commitMaxTimeout != null
&& System.currentTimeMillis() - startMillis
Expand All @@ -762,6 +762,8 @@ private int tryCommit(
"Commit failed after %s millis with %s retries, there maybe exist commit conflicts between multiple jobs.",
commitMaxTimeout.toMillis(), retryCount));
}

retryCount++;
}
return retryCount + 1;
}
Expand Down Expand Up @@ -1067,7 +1069,7 @@ public void compactManifest() {
break;
}

retryCount++;


if ((commitMaxTimeout != null
&& System.currentTimeMillis() - startMillis
Expand All @@ -1079,6 +1081,8 @@ public void compactManifest() {
"Commit failed after %s millis with %s retries, there maybe exist commit conflicts between multiple jobs.",
commitMaxTimeout.toMillis(), retryCount));
}

retryCount++;
}
}

Expand Down

0 comments on commit ae475ef

Please sign in to comment.