Skip to content

Commit

Permalink
Add info log between executing work failed and cleanup (apache#32570)
Browse files Browse the repository at this point in the history
  • Loading branch information
Abacn authored Sep 26, 2024
1 parent 91c9be4 commit 7c565c3
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -410,6 +410,7 @@ private ExecuteWorkResult executeWork(
// If processing failed due to a thrown exception, close the executionState. Do not
// return/release the executionState back to computationState as that will lead to this
// executionState instance being reused.
LOG.info("Invalidating executor after work item {} failed with Exception:", key, t);
computationWorkExecutor.invalidate();

// Re-throw the exception, it will be caught and handled by workFailureProcessor downstream.
Expand Down

0 comments on commit 7c565c3

Please sign in to comment.