search

ptgoetz / storm-signals

Storm primitives to allow out-of-band messaging to storm spouts and bolts.
87 stars 27 forks source link

illegal argument exception with SignalClient #6

Open ppjogani opened 9 years ago

ppjogani commented 9 years ago

SignalClient sc = new SignalClient("xx.xx.xx.xx:2181", "spout");

gives a 

Exception in thread "main" java.lang.IllegalArgumentException: Path must start with / character
    at org.apache.curator.utils.PathUtils.validatePath(PathUtils.java:54)
    at org.apache.curator.utils.PathUtils.validatePath(PathUtils.java:37)
    at org.apache.curator.utils.ZKPaths.fixForNamespace(ZKPaths.java:63)
    at org.apache.curator.framework.imps.NamespaceImpl.fixForNamespace(NamespaceImpl.java:82)
    at org.apache.curator.framework.imps.CuratorFrameworkImpl.fixForNamespace(CuratorFrameworkImpl.java:574)
    at org.apache.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:139)
    at org.apache.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:36)
    at backtype.storm.contrib.signals.client.SignalClient.send(SignalClient.java:36)
    at storm.signalclient.TestSignalClient.main(TestSignalClient.java:11)

this is contrary to the README usage example. I did try adding /, did not help.

L3O commented 7 years ago

Any update on this ?

itsmkj commented 6 years ago

Just replace this.name with "/"+ this.name everywhere the path is used