You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/09/18 22:36:54 UTC
kafka git commit: KAFKA-5833: Reset thread interrupt state in case of
InterruptedException
Repository: kafka
Updated Branches:
refs/heads/trunk 4ac7c48e9 -> f46d414c1
KAFKA-5833: Reset thread interrupt state in case of InterruptedException
Author: Matthias J. Sax <ma...@confluent.io>
Reviewers: Ted Yu <yu...@gmail.com>, Guozhang Wang <wa...@gmail.com>
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 <ma...@confluent.io>
Authored: Tue Sep 19 06:36:47 2017 +0800
Committer: Guozhang Wang <wa...@gmail.com>
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();