异常:submittopology失败:无序响应

yuvru6vn  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(271)

我运行了一些java代码,它会上传示例中的:storm-starter-topologies-0.9.6.jar,控制台显示:
535[main]info backtype.storm.stormsubmitter-将拓扑jar c:\apachestorm096\examples\storm starter\storm-starter-topologies-0.9.6.jar上载到指定位置:¨/usr/本地/风暴/数据¨/nimbus/inbox/stormjar-8b5acdaf-e6ce-4b01-9ea9-9bd92e30f417.jar
1066[main]info backtype.storm.stormsubmitter-已成功将拓扑jar上载到指定位置:¨/usr/本地/风暴/数据¨/nimbus/inbox/stormjar-8b5acdaf-e6ce-4b01-9ea9-9bd92e30f417.jar
但我也有一个错误:
线程“main”org.apache.thrift7.tapplicationexception中出现异常:submittopology失败:响应顺序错误
在storm ui中显示提交的拓扑。。。但是什么都没有发生,没有溪流,没有喷口,没有 lightning 。。。没有工人。。。eclipse在本地运行,storm+zookeeper在虚拟机上运行。
代码如下:

  1. TopologyBuilder builder = new TopologyBuilder();
  2. Config conf = new Config();
  3. conf.put(Config.NIMBUS_HOST, "100.0.0.26");
  4. conf.put(Config.STORM_ZOOKEEPER_PORT, "2181");
  5. conf.setNumWorkers(20);
  6. conf.setMaxSpoutPending(5000);
  7. StormSubmitter submitter = new StormSubmitter();
  8. conf.setDebug(true);
  9. Map storm_conf = Utils.readStormConfig();
  10. storm_conf.put("nimbus.host", "100.0.0.26");
  11. Client client = NimbusClient.getConfiguredClient(storm_conf).getClient();
  12. try {
  13. NimbusClient nimbus = new NimbusClient(storm_conf, "100.0.0.26", 6627);
  14. //submitter.submitTopology("blub", conf, builder.createTopology());
  15. String inputJar = "C:\\apachestorm096\\examples\\storm-starter\\storm-starter-topologies-0.9.6.jar";
  16. // upload topology jar to Cluster using StormSubmitter
  17. String uploadedJarLocation = StormSubmitter.submitJar(storm_conf,inputJar);
  18. System.out.println("Try ... ");
  19. try {
  20. String jsonConf = JSONValue.toJSONString(storm_conf);
  21. System.out.println("Config : " + jsonConf );
  22. nimbus.getClient().send_getNimbusConf();
  23. Thread.sleep(5000);
  24. System.out.println("Out of sleep ... ");
  25. nimbus.getClient().submitTopology("word-count", uploadedJarLocation, jsonConf, builder.createTopology());
  26. } catch (AlreadyAliveException e) { // (AlreadyAliveException ae) {
  27. e.printStackTrace();
  28. }
68de4m5k

68de4m5k1#

由于设置的配置参数太少,因此引发错误。我忘了设置nimbus\u thrift\u端口,我还更改了配置的定义方式。。。

  1. TopologyBuilder builder = new TopologyBuilder();
  2. Map conf = new HashMap();
  3. //Map conf = Utils.readStormConfig();
  4. conf.put(Config.NIMBUS_HOST, "100.0.0.26");
  5. conf.put(Config.NIMBUS_THRIFT_PORT , 6627 );
  6. conf.put(Config.STORM_ZOOKEEPER_PORT, 2181 );
  7. conf.put(Config.TOPOLOGY_WORKERS , 4);
  8. conf.put("storm.thrift.transport", "backtype.storm.security.auth.SimpleTransportPlugin");

相关问题