Repository: kafka Updated Branches: refs/heads/trunk 4ac7c48e9 -> f46d414c1
KAFKA-5833: Reset thread interrupt state in case of InterruptedException Author: Matthias J. Sax <[email protected]> Reviewers: Ted Yu <[email protected]>, Guozhang Wang <[email protected]> Closes #3841 from mjsax/kafka-5833-interrupts Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f46d414c Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/f46d414c Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/f46d414c Branch: refs/heads/trunk Commit: f46d414c1643e15bc5b7a152b8df475aacd1e66d Parents: 4ac7c48 Author: Matthias J. Sax <[email protected]> Authored: Tue Sep 19 06:36:47 2017 +0800 Committer: Guozhang Wang <[email protected]> Committed: Tue Sep 19 06:36:47 2017 +0800 ---------------------------------------------------------------------- .../test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/f46d414c/streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java ---------------------------------------------------------------------- diff --git a/streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java b/streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java index 1e4afcd..d1e3206 100644 --- a/streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java +++ b/streams/src/test/java/org/apache/kafka/streams/perf/SimpleBenchmark.java @@ -392,7 +392,7 @@ public class SimpleBenchmark { try { latch.await(); } catch (InterruptedException ex) { - //ignore + Thread.currentThread().interrupt(); } } long endTime = System.currentTimeMillis();
