HuangZhenQiu commented on code in PR #25770:
URL: https://github.com/apache/flink/pull/25770#discussion_r1883864849
##########
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java:
##########
@@ -1243,7 +1246,8 @@ public void goToRestarting(
OperatorCoordinatorHandler operatorCoordinatorHandler,
Duration backoffTime,
boolean forcedRestart,
- List<ExceptionHistoryEntry> failureCollection) {
+ List<ExceptionHistoryEntry> failureCollection,
+ boolean isFromFailure) {
Review Comment:
It is a good question. If so, we need to keep a map <JobID, Long> in
scheduler to record previous failure number for given JobID. Each time we need
to compare the current number with number in the map, and update the numer
accordingly. Is it a reasonable solution?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
