apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "bright chen (JIRA)" <j...@apache.org>
Subject [jira] [Created] (APEXMALHAR-2133) Got NullPointerException when run KafkaInputOperatorTest unit test in Travis
Date Tue, 05 Jul 2016 20:01:11 GMT
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)

Mime
View raw message