喷口和螺栓信息时，风暴罐子使用灵气客户端部署在风暴UI失踪

How to submit a topology in storm production cluster using IDE

Below is my implementation 

TopologyBuilder builder = new TopologyBuilder(); 

     Map storm_conf = Utils.readStormConfig(); 
     storm_conf.put("nimbus.host", "localhost"); 
     Nimbus.Client client = NimbusClient.getConfiguredClient(storm_conf) 
       .getClient(); 
     String inputJar = "/home/user/TestType-1.0.jar"; 
     NimbusClient nimbus = null; 
     try { 
      nimbus = new NimbusClient(storm_conf, "localhost", 6627); 
     } catch (TTransportException e) { 
      System.out.println("unable to connect to client"); 
      e.printStackTrace(); 
     } 

     System.setProperty("storm.jar", "/home/user/TestType-1.0.jar"); 

     String jsonConf = JSONValue.toJSONString(storm_conf); 
     try { 
      nimbus.getClient().submitTopology("SellerPageTypeTopology", 
        "/home/user/TestType-1.0.jar", jsonConf, builder.createTopology()); 
     } catch (AlreadyAliveException e) { 
      e.printStackTrace(); 
     } catch (InvalidTopologyException e) { 
      e.printStackTrace(); 
     } catch (Exception e) { 
      e.printStackTrace(); 
     }

我是能够成功地部署拓扑跟着一个例子。在暴风雨中，我能够看到拓扑活动，但喷嘴和螺栓细节丢失。任何想法是什么我想念失踪。谢谢您的帮助。

来源

2016-03-10 user3514641

您已经创建了一个空的拓扑，然后提交了它。你的嘴和螺栓没有显示出来，因为你还没有加入他们还没有到您TopologyBuilder：

Config config = new Config(); 
TopologyBuilder builder = new TopologyBuilder(); 
builder.setSpout(MY_SPOUT_ID, mySpout); 
builder.setBolt(MY_BOLT1_ID, myBolt1, 2).shuffleGrouping(MY_SPOUT_ID); 
builder.setBolt(MY_BOLT2_ID, myBolt2).shuffleGrouping(MY_SPOUT_ID);

参考：https://docs.hortonworks.com/HDPDocuments/HDP2/HDP-2.3.2/bk_storm-user-guide/content/storm-parallelism.html

来源

2016-03-14 17:18:37

我宣布嘴和螺栓装在罐子我。可能我错过了一种在NimbusClient API中指定主类的方法。 – user3514641

喷口和螺栓信息时，风暴罐子使用灵气客户端部署在风暴UI失踪

回答

相关问题