Rambrij Chauhan created APEXCORE-523:
----------------------------------------
Summary: Error while connecting with Kafka using Apache Apex
Key: APEXCORE-523
URL: https://issues.apache.org/jira/browse/APEXCORE-523
Project: Apache Apex Core
Issue Type: Bug
Reporter: Rambrij Chauhan
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)
