apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (APEXMALHAR-2133) Got NullPointerException when run KafkaInputOperatorTest unit test in Travis
Date Tue, 05 Jul 2016 20:41:11 GMT

    [ 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 <bright@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)

Mime
View raw message