kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: HOTFIX: Fix NPE after standby task reassignment
Date Tue, 09 Feb 2016 18:02:25 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 9f5a1f876 -> 6352a30f4


HOTFIX: Fix NPE after standby task reassignment

Buffered records of change logs must be cleared upon reassignment of standby tasks.

Author: Yasuhiro Matsuda <yasuhiro@confluent.io>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

Closes #889 from ymatsuda/hotfix


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6352a30f
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/6352a30f
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/6352a30f

Branch: refs/heads/trunk
Commit: 6352a30f46f2da11a8dc3e58912d0a2db8284c35
Parents: 9f5a1f8
Author: Yasuhiro Matsuda <yasuhiro@confluent.io>
Authored: Tue Feb 9 10:02:20 2016 -0800
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Tue Feb 9 10:02:20 2016 -0800

----------------------------------------------------------------------
 .../org/apache/kafka/streams/processor/internals/StreamThread.java  | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/6352a30f/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
index 6a8eabc..d51974a 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
@@ -682,6 +682,7 @@ public class StreamThread extends Thread {
 
         standbyTasks.clear();
         standbyTasksByPartition.clear();
+        standbyRecords.clear();
     }
 
     private void ensureCopartitioning(Collection<Set<String>> copartitionGroups)
{


Mime
View raw message