You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@apex.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/05 20:41:11 UTC
[jira] [Commented] (APEXMALHAR-2133) Got NullPointerException when
run KafkaInputOperatorTest unit test in Travis
[ https://issues.apache.org/jira/browse/APEXMALHAR-2133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15363194#comment-15363194 ]
ASF GitHub Bot commented on APEXMALHAR-2133:
--------------------------------------------
GitHub user brightchen opened a pull request:
https://github.com/apache/apex-malhar/pull/331
APEXMALHAR-2133 #resolve #comment Handle case partitionsFor() returns…
… null
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/brightchen/apex-malhar APEXMALHAR-2133
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/apex-malhar/pull/331.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #331
----
commit 1d440015dccc2e51f410b2bebc2a591f0e108a8a
Author: brightchen <br...@datatorrent.com>
Date: 2016-07-05T20:39:06Z
APEXMALHAR-2133 #resolve #comment Handle case partitionsFor() returns null
----
> 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)