Skip to content

Commit 8e01a32

Browse files
committed
addressing PR comments
1 parent f07eea4 commit 8e01a32

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

tez-common/src/main/java/org/apache/tez/common/AsyncDispatcher.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -196,6 +196,9 @@ protected void dispatch(Event event) {
196196
} else {
197197
throw new Exception("No handler for registered for " + type);
198198
}
199+
} catch (InterruptedException ie) {
200+
LOG.warn("Interrupted Exception while handling event: " + event.getType(), ie);
201+
Thread.currentThread().interrupt();
199202
} catch (Throwable t) {
200203
LOG.error("Error in dispatcher thread", t);
201204
// If serviceStop is called, we should exit this thread gracefully.

0 commit comments

Comments
 (0)