[
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 <[email protected]>
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)
