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-2227) Error while connecting with Kafka using Apache Apex
Date Wed, 07 Sep 2016 16:05:20 GMT

    [ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15471013#comment-15471013
] 

ASF GitHub Bot commented on APEXMALHAR-2227:
--------------------------------------------

GitHub user chandnisingh opened a pull request:

    https://github.com/apache/apex-malhar/pull/402

    APEXMALHAR-2227 Index out of Bound Exception fix in Kafka input

    @siyuanh @tweise 

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/chandnisingh/apex-malhar APEXMALHAR-2227

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/apex-malhar/pull/402.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 #402
    
----
commit 4be08859ec55da2fb0b2e85bed7431d4e2c5dcf8
Author: Chandni Singh <csingh@apache.org>
Date:   2016-09-07T15:58:09Z

    APEXMALHAR-2227 Index out of Bound Exception fix in Kafka input

----


> Error while connecting with Kafka using Apache Apex
> ---------------------------------------------------
>
>                 Key: APEXMALHAR-2227
>                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2227
>             Project: Apache Apex Malhar
>          Issue Type: Bug
>    Affects Versions: 3.4.0
>            Reporter: Rambrij Chauhan
>            Assignee: Chandni Singh
>            Priority: Blocker
>
> Hi,
> I am working on Apache Apex and trying to implement KafkaInputOperator provided by apex-malhar
but I am hitting with following exception as soon as i am running the application:-
> Strange thing is, the same application working for other zookeeper ip but not for that
IP i need it to work so i went and check the version of respective zookeeper and found that,
the one which is working belongs to 0.8.1.1 and other one is 0.8.2.0. Could you kindly help
me out for some work arround, i really need to work on with the IP which belongs to 0.8.2.0.
> java.lang.RuntimeException: Error creating local cluster
> 	at com.datatorrent.stram.LocalModeImpl.getController(LocalModeImpl.java:78)
> 	at org.capitalone.apex.main.ApplicationTest.testSomeMethod(ApplicationTest.java:14)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 	at java.lang.reflect.Method.invoke(Method.java:498)
> 	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
> 	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
> 	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
> 	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
> 	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
> 	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
> 	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
> 	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:236)
> 	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:53)
> 	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:229)
> 	at org.junit.runners.ParentRunner.run(ParentRunner.java:309)
> 	at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
> 	at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
> 	at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
> 	at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:678)
> 	at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
> 	at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
> Caused by: java.lang.IllegalStateException: Partitioner returns null or empty.
> 	at com.datatorrent.stram.plan.physical.PhysicalPlan.initPartitioning(PhysicalPlan.java:755)
> 	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)
> 	... 24 more



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message