分享

请教Jstorm发布Topology问题

caiyifeng 发表于 2015-10-24 20:13:17 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 3 12271
平时我们发布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

已有(3)人评论

跳转到指定楼层
bioger_hit 发表于 2015-10-24 20:55:40
拓扑是否有问题 topology 为null
回复

使用道具 举报

caiyifeng 发表于 2015-10-24 21:51:46
bioger_hit 发表于 2015-10-24 20:55
拓扑是否有问题 topology 为null

Topolog应该没问题,我调试过了,submitTopology()中的所有参赛都不为null。而且我改为./jstorm jar xx 的方式发布Topology,是可以运行的
nimbus.getClient().submitTopology(topology.getTopologyId(), uploadLocation, jsonConf, topology.buildTopology());
回复

使用道具 举报

bioger_hit 发表于 2015-10-25 17:28:39
caiyifeng 发表于 2015-10-24 21:51
Topolog应该没问题,我调试过了,submitTopology()中的所有参赛都不为null。而且我改为./jstorm jar xx ...

可能是本地环境的问题,版本是否一致,jar是否加全了,等等问题
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条