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 <[email protected]> Reviewers: Ewen Cheslack-Postava <[email protected]> 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 <[email protected]> Authored: Tue Feb 9 10:02:20 2016 -0800 Committer: Ewen Cheslack-Postava <[email protected]> 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) {
