[jira] [Created] (SAMZA-802) KafkaSystemConsumer needs to handle empty topic offsets

[Yi Pan (Data Infrastructure) (JIRA)]

Yi Pan (Data Infrastructure) created SAMZA-802:
--------------------------------------------------

             Summary: KafkaSystemConsumer needs to handle empty topic offsets
                 Key: SAMZA-802
                 URL: https://issues.apache.org/jira/browse/SAMZA-802
             Project: Samza
          Issue Type: Bug
            Reporter: Yi Pan (Data Infrastructure)


We have encountered multiple times in NullPointerException in KafkaSystemAdmin 
when the topic is empty:
{code}
2015-10-19 18:21:03 KafkaSystemAdmin$ [INFO] Got metadata: 
Map(__samza_coordinator_employment-online-ingestion_i001 -> 
SystemStreamMetadata 
[streamName=__samza_coordinator_employment-online-ingestion_i001, 
partitionMetadata={Partition [partition=0]=SystemStreamPartitionMetadata 
[oldestOffset=null, newestOffset=null, upcomingOffset=0]}])
Exception in thread "main" java.lang.NullPointerException
        at 
java.util.concurrent.ConcurrentHashMap.putVal(ConcurrentHashMap.java:1011)
        at 
java.util.concurrent.ConcurrentHashMap.put(ConcurrentHashMap.java:1006)
        at 
scala.collection.convert.Wrappers$JMapWrapperLike$class.update(Wrappers.scala:257)
        at 
scala.collection.convert.Wrappers$JConcurrentMapWrapper.update(Wrappers.scala:348)
        at 
scala.collection.mutable.MapLike$class.getOrElseUpdate(MapLike.scala:189)
        at scala.collection.mutable.AbstractMap.getOrElseUpdate(Map.scala:91)
        at 
org.apache.samza.system.kafka.KafkaSystemConsumer.register(KafkaSystemConsumer.scala:108)
        at 
org.apache.samza.coordinator.stream.CoordinatorStreamSystemConsumer.register(CoordinatorStreamSystemConsumer.java:112)
        at org.apache.samza.job.JobRunner.run(JobRunner.scala:111)
        at org.apache.samza.job.JobRunner$.main(JobRunner.scala:66)
        at org.apache.samza.job.JobRunner.main(JobRunner.scala)
{code}

KafkaSystemAdmin needs to handle this case.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)