[ https://issues.apache.org/jira/browse/KAFKA-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Michael Noll updated KAFKA-3324: -------------------------------- Description: KAFKA-3311 changed {{streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java}}, which triggers NPEs consistently at this line: {code} for (Map.Entry<String, Set<TaskId>> entry : internalSourceTopicToTaskIds.entrySet()) { {code} The impact is significant unfortunately because any end-to-end Streams job that I have been running keeps failing currently because of this bug. *How to fix* The naive fix -- a simple null check -- seems to resolve the problem. PR incoming. was: KAFKA-3311 changed {{streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java}}, which unfortunately triggers NPEs consistently at this line: {code} for (Map.Entry<String, Set<TaskId>> entry : internalSourceTopicToTaskIds.entrySet()) { {code} The naive bug fix -- a simple null check -- seems to resolve the problem. PR incoming. > NullPointerException in StreamPartitionAssignor (Kafka Streams) > --------------------------------------------------------------- > > Key: KAFKA-3324 > URL: https://issues.apache.org/jira/browse/KAFKA-3324 > Project: Kafka > Issue Type: Bug > Components: kafka streams > Affects Versions: 0.10.0.0 > Reporter: Michael Noll > > KAFKA-3311 changed > {{streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java}}, > which triggers NPEs consistently at this line: > {code} > for (Map.Entry<String, Set<TaskId>> entry : > internalSourceTopicToTaskIds.entrySet()) { > {code} > The impact is significant unfortunately because any end-to-end Streams job > that I have been running keeps failing currently because of this bug. > *How to fix* > The naive fix -- a simple null check -- seems to resolve the problem. PR > incoming. -- This message was sent by Atlassian JIRA (v6.3.4#6332)