[
https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15471182#comment-15471182
]
Chandni Singh commented on APEXMALHAR-2227:
-------------------------------------------
Hi,
We will need to make the fix in the Malhar 3.5.0 release branch and push it to
maven repo. So yes you will need to download the malhar jar again from maven
repo.
Another quick way is to get the source code by cloning the Malhar repo. Switch
to 3.5.0 release branch. Making the fix and building it.
The fix is quite trivial. You can see the change that needs to be done here:
https://github.com/apache/apex-malhar/pull/402
Thanks,
Chandni
> 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)
