Reset thread interrupt state in case of InterruptedException
Author: Matthias J. Sax
Reviewers: Ted Yu Guozhang Wang
Closes from mjsax/kafka-5833-interrupts
@@ -392,7 +392,7 @@ public class SimpleBenchmark {
try {
latch.await();
} catch (InterruptedException ex) {
- //ignore
+ Thread.currentThread().interrupt();
}
}
long endTime = System.currentTimeMillis();
