Hi I am using Kafka 8 to run this hybrid example. I get this exceptions when I try to run (It says the error is because it expects the path length to be > 0 and is found to be 0). Any idea on how to fix this?
14/11/18 14:55:57 ERROR proto.RunHybrid$: ingestion error
java.lang.ExceptionInInitializerError
at summingbird.proto.RunHybrid$$anon$1.run(HybridRunner.scala:88)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.IllegalArgumentException: Path length must be > 0
at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48)
at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35)
at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:626)
at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213)
at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223)
at kafka.utils.ZkUtils$.createParentPath(Unknown Source)
at kafka.utils.ZkUtils$.createEphemeralPath(Unknown Source)
at kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(Unknown Source)
at kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(Unknown Source)
at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(Unknown Source)
at kafka.consumer.ZookeeperConsumerConnector.consume(Unknown Source)
at kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(Unknown Source)
at kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(Unknown Source)
at summingbird.proto.Ingestion$.(Ingestion.scala:33)
at summingbird.proto.Ingestion$.(Ingestion.scala)
... 8 more
Hi I am using Kafka 8 to run this hybrid example. I get this exceptions when I try to run (It says the error is because it expects the path length to be > 0 and is found to be 0). Any idea on how to fix this?
14/11/18 14:55:57 ERROR proto.RunHybrid$: ingestion error java.lang.ExceptionInInitializerError at summingbird.proto.RunHybrid$$anon$1.run(HybridRunner.scala:88) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask.run(FutureTask.java:262) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:745) Caused by: java.lang.IllegalArgumentException: Path length must be > 0 at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:48) at org.apache.zookeeper.common.PathUtils.validatePath(PathUtils.java:35) at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:626) at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87) at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308) at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304) at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:213) at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223) at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223) at org.I0Itec.zkclient.ZkClient.createPersistent(ZkClient.java:223) at kafka.utils.ZkUtils$.createParentPath(Unknown Source) at kafka.utils.ZkUtils$.createEphemeralPath(Unknown Source) at kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(Unknown Source) at kafka.utils.ZkUtils$.createEphemeralPathExpectConflictHandleZKBug(Unknown Source) at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$registerConsumerInZK(Unknown Source) at kafka.consumer.ZookeeperConsumerConnector.consume(Unknown Source) at kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(Unknown Source) at kafka.consumer.ZookeeperConsumerConnector.createMessageStreams(Unknown Source) at summingbird.proto.Ingestion$.(Ingestion.scala:33)
at summingbird.proto.Ingestion$.(Ingestion.scala)
... 8 more