开发者社区> 问答> 正文

JStorm的客户端提交问题?报错

平时我们发布Topology,都是在后台用 ./jstorm jar xxxxx.jar com.xxxx.xxxTopolog arg0,arg1 来将Topology发布到storm上

现在我用程序直接去发布Topology,但老是出现问题:
Topology发布的代码:

           nimbus.getClient().submitTopology(topology.getTopologyId(), uploadLocation, jsonConf, topology.buildTopology());

报错信息如下:

[INFO  2015-10-25 10:56:36 ServiceHandler:1090 pool-7-thread-12] Begin to copy from /home/hduser/app/jstorm/data/nimbus/inbox/0436d8e8-dab1-49ab-937f-a111f99a6898/stormjar-0436d8e8-dab1-49ab-937f-a111f99a6898.jar/lib to /home/hduser/app/jstorm/data/nimbus/stormdist/testTopology-3-1445741796/lib
[INFO  2015-10-25 10:56:36 ServiceHandler:1094 pool-7-thread-12] No lib jars /home/hduser/app/jstorm/data/nimbus/inbox/0436d8e8-dab1-49ab-937f-a111f99a6898/stormjar-0436d8e8-dab1-49ab-937f-a111f99a6898.jar/lib
[ERROR  2015-10-25 10:56:36 ServiceHandler:247 pool-7-thread-12] Fail to sumbit topology null, cause:null


topologyId:testTopology-3-1445741796, uploadedJarLocation:/home/hduser/app/jstorm/data/nimbus/inbox/0436d8e8-dab1-49ab-937f-a111f99a6898/stormjar-0436d8e8-dab1-49ab-937f-a111f99a6898.jar


java.lang.NullPointerException
at com.alibaba.jstorm.utils.PathUtils.read_dir_contents(PathUtils.java:107)
at com.alibaba.jstorm.daemon.nimbus.ServiceHandler.setupJar(ServiceHandler.java:1119)
at com.alibaba.jstorm.daemon.nimbus.ServiceHandler.setupStormCode(ServiceHandler.java:1073)
at com.alibaba.jstorm.daemon.nimbus.ServiceHandler.submitTopologyWithOpts(ServiceHandler.java:200)
at com.alibaba.jstorm.daemon.nimbus.ServiceHandler.submitTopology(ServiceHandler.java:106)
at backtype.storm.generated.Nimbus$Processor$submitTopology.getResult(Nimbus.java:1609)
at backtype.storm.generated.Nimbus$Processor$submitTopology.getResult(Nimbus.java:1597)
at org.apache.thrift7.ProcessFunction.process(ProcessFunction.java:32)
at org.apache.thrift7.TBaseProcessor.process(TBaseProcessor.java:34)
at org.apache.thrift7.server.TNonblockingServer$FrameBuffer.invoke(TNonblockingServer.java:632)
at org.apache.thrift7.server.THsHaServer$Invocation.run(THsHaServer.java:201)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)


展开
收起
爱吃鱼的程序员 2020-06-12 10:34:21 518 0
1 条回答
写回答
取消 提交回答
  • https://developer.aliyun.com/profile/5yerqm5bn5yqg?spm=a2c6h.12873639.0.0.6eae304abcjaIB

    你敢用,也是个奇才

    2020-06-12 10:34:39
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
基于RocketMQ Connect 构建全新数据流转处理平 立即下载
gohbase :HBase go客户端 立即下载
Apache Flink 流式应用中状态的数据结构定义升级 立即下载