Prevent interrupted exception from polluting log during supervisor shutdown (#4253)

* Prevent interrupted exception from polluting log during supervisor shutdown

* do nothing in case of InterruptedException
This commit is contained in:
Parag Jain 2017-05-08 17:05:25 -05:00 committed by Fangjin Yang
parent e02f783e82
commit eb8e1b0a97
1 changed files with 3 additions and 0 deletions

View File

@ -1794,6 +1794,9 @@ public class KafkaSupervisor implements Supervisor
ServiceMetricEvent.builder().setDimension("dataSource", dataSource).build("ingest/kafka/lag", lag)
);
}
catch (InterruptedException e) {
// do nothing, probably we are shutting down
}
catch (Exception e) {
log.warn(e, "Unable to compute Kafka lag");
}