bright chen created APEXMALHAR-2133:
---------------------------------------
Summary: Got NullPointerException when run KafkaInputOperatorTest
unit test in Travis
Key: APEXMALHAR-2133
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2133
Project: Apache Apex Malhar
Issue Type: Bug
Reporter: bright chen
Assignee: bright chen
This exception never happened when test in local machine.
2016-07-05 17:13:52,705 [ProcessThread(sid:0 cport:-1):] INFO
server.PrepRequestProcessor pRequest - Got user-level KeeperException when
processing sessionid:0x155bc0bfb230000 type:create cxid:0x244 zxid:0x148
txntype:-1 reqpath:n/a Error Path:/brokers/topics/testtopic12/partitions
Error:KeeperErrorCode = NoNode for /brokers/topics/testtopic12/partitions
2016-07-05 17:13:52,707 [main] ERROR kafka.AbstractKafkaPartitioner
definePartitions - assign() exception.
java.lang.NullPointerException
at
org.apache.apex.malhar.kafka.OneToOnePartitioner.assign(OneToOnePartitioner.java:52)
at
org.apache.apex.malhar.kafka.AbstractKafkaPartitioner.definePartitions(AbstractKafkaPartitioner.java:131)
at
org.apache.apex.malhar.kafka.AbstractKafkaInputOperator.definePartitions(AbstractKafkaInputOperator.java:356)
at
com.datatorrent.stram.plan.physical.PhysicalPlan.initPartitioning(PhysicalPlan.java:752)
at
com.datatorrent.stram.plan.physical.PhysicalPlan.addLogicalOperator(PhysicalPlan.java:1676)
at
com.datatorrent.stram.plan.physical.PhysicalPlan.<init>(PhysicalPlan.java:378)
at
com.datatorrent.stram.StreamingContainerManager.<init>(StreamingContainerManager.java:418)
at
com.datatorrent.stram.StreamingContainerManager.<init>(StreamingContainerManager.java:406)
at
com.datatorrent.stram.StramLocalCluster.<init>(StramLocalCluster.java:299)
at
com.datatorrent.stram.LocalModeImpl.getController(LocalModeImpl.java:76)
at
org.apache.apex.malhar.kafka.KafkaInputOperatorTest.testInputOperator(KafkaInputOperatorTest.java:346)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
