kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-5833: Reset thread interrupt state in case of InterruptedException
Date Mon, 18 Sep 2017 22:36:54 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 4ac7c48e9 -> f46d414c1


KAFKA-5833: Reset thread interrupt state in case of InterruptedException

Author: Matthias J. Sax <matthias@confluent.io>

Reviewers: Ted Yu <yuzhihong@gmail.com>, Guozhang Wang <wangguoz@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 <matthias@confluent.io>
Authored: Tue Sep 19 06:36:47 2017 +0800
Committer: Guozhang Wang <wangguoz@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();


Mime
View raw message