平时我们发布Topology,都是在后台用 ./jstorm jar xxxxx.jar com.xxxx.xxxTopolog arg0,arg1 来将Topology发布到storm上
现在我用程序直接去发布Topology,但老是出现问题:
Topology发布的代码:
nimbus.getClient().submitTopology(topology.getTopologyId(), uploadLocation, jsonConf, topology.buildTopology());
报错信息如下:
Exception in thread "main" TopologyAssignException(msg:Fail to sumbit topology null, cause:null
topologyId:testTopology-6-1445666476, uploadedJarLocation:/home/hduser/app/jstorm/data/nimbus/inbox/a1c2a28d-4430-431e-b032-fcfa5cea240c/stormjar-a1c2a28d-4430-431e-b032-fcfa5cea240c.jar
)
不知这问题何解??哪位能解答一下。或者有完整的提交程序。 我用得JStorm
|
|