alecinvan
commented
9 years ago I tried to change the storm.zkroot, but it always come up such error
play.api.Application$$anon$1: Execution exception[[NoNodeException: KeeperErrorCode = NoNode for /transactional/pipe_test_group/spoutInit/coordinator/user]]
Here is where my trident topo data is stored:
[zk: localhost:2181(CONNECTED) 2] ls /transactional/pipe_test_group/spoutInit [coordinator, user]
If I set -Dcapillary.storm.zkroot= /transactional/pipe_test_group/spoutInit, it seems to pick up /transactional/pipe_test_group/spoutInit/coordinator first, instead of /user
How can I set this parameter?
thanks
zhaoxiaojie0415
Hi,
I 'v never been able to run capillary successfully. Here is how I set the zkroot in trident topo:
Config.TRANSACTIONAL_ZOOKEEPER_ROOT=/transactional/pipe_test_group
And the structure of root directory is [zk: localhost:2181(CONNECTED) 8] ls /transactional/pipe_test_group/spoutInit/user [partition_3, partition_4, partition_1, partition_2, partition_6, partition_0, partition_5, partition_7]
The root is: [zk: localhost:2181(CONNECTED) 0] ls / [transactional, zookeeper, admin, consumers, config, controller, kafka-manager, storm, brokers, controller_epoch]
I tried many times by setting different -Dcapillary.kafka.zkroot, it always ends up internal server error, like play.api.Application$$anon$1: Execution exception[[JsonMappingException: No content to map due to end-of-input at [Source: java.io.StringReader@20af6368; line: 1, column: 1]]] at play.api.Application$class.handleError(Application.scala:296) ~[com.typesafe.play.play_2.10-2.3.4.jar:2.3.4] at play.api.DefaultApplication.handleError(Application.scala:402) [com.typesafe.play.play_2.10-2.3.4.jar:2.3.4] at play.core.server.netty.PlayDefaultUpstreamHandler$$anonfun$14$$anonfun$apply$1.applyOrElse(PlayDefaultUpstreamHandler.scala:205) [com.typesafe.play.play_2.10-2.3.4.jar:2.3.4] at play.core.server.netty.PlayDefaultUpstreamHandler$$anonfun$14$$anonfun$apply$1.applyOrElse(PlayDefaultUpstreamHandler.scala:202) [com.typesafe.play.play_2.10-2.3.4.jar:2.3.4] at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:33) [org.scala-lang.scala-library-2.10.4.jar:na] Caused by: com.fasterxml.jackson.databind.JsonMappingException: No content to map due to end-of-input at [Source: java.io.StringReader@20af6368; line: 1, column: 1] at com.fasterxml.jackson.databind.JsonMappingException.from(JsonMappingException.java:164) ~[com.fasterxml.jackson.core.jackson-databind-2.3.2.jar:2.3.2] at com.fasterxml.jackson.databind.ObjectMapper._initForReading(ObjectMapper.java:3036) ~[com.fasterxml.jackson.core.jackson-databind-2.3.2.jar:2.3.2] at com.fasterxml.jackson.databind.ObjectMapper._readValue(ObjectMapper.java:2951) ~[com.fasterxml.jackson.core.jackson-databind-2.3.2.jar:2.3.2] at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:1587) ~[com.fasterxml.jackson.core.jackson-databind-2.3.2.jar:2.3.2] at play.api.libs.json.JacksonJson$.parseJsValue(JsValue.scala:486) ~[com.typesafe.play.play-json_2.10-2.3.4.jar:2.3.4]
This is one command: bin/capillary -Dcapillary.zookeepers=10.100.71.33:2181,10.100.70.28:2181,10.100.70.29:2181 -Dcapillary.kafka.zkroot=/transactional/pipe_test_group
Can you provide exactly command how to run it?
thanks