commit e725b891ac469e901bfe50de567f64c1ad88b366
author Siyuan Hua <siyuan@datatorrent.com> Thu Apr 16 13:41:11 2015 -0700
committer Tushar Gosavi <tushar@datatorrent.com> Fri Apr 17 11:48:14 2015 +0530
tree a7d570095cb196aea5321343fb6b6eb9ca52745d
parent c7964f90876504b3001c7378a167caf9e582ee1a

Check value

contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java

diff --git a/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
index 09b1234..7f8688f 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
@@ -738,7 +738,7 @@
           return false;
         }
         for (Map.Entry<String, List<PartitionMetadata>> en : partitionsMeta.entrySet()) {
-          if(en == null){
+          if(en.getValue() == null){
             //broker(s) has temporary issue to get metadata
             continue;
           }