【发布时间】:2019-10-16 03:35:56
【问题描述】:
通过stormsubmitter.submittopoloy 提交我的拓扑。在storm UI中可以看到topo,但是发出的数字总是0。
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("WordSpout", new WordSpout());
builder.setBolt("WordSplitBolt", new WordSplitBolt(),5).shuffleGrouping("WordSpout");
builder.setBolt("WordCountBolt", new WordCountBolt(),5).fieldsGrouping("WordSplitBolt", new Fields("word"));
builder.setBolt("WordReportBolt", new WordReportBolt(),10).globalGrouping("WordCountBolt");
Config cfg = new Config();
cfg.setDebug(true);
try{
StormSubmitter.submitTopology("wordcount-topo", cfg, builder.createTopology());
}
catch (AlreadyAliveException e)
{
}
catch (InvalidTopologyException e)
{
}
catch (AuthorizationException e)
{
}
在此处查看屏幕截图:https://i.stack.imgur.com/w7JrG.jpg
在work.log 文件中收到以下错误:
2019-10-16 11:51:08.973 STDERR Thread-0 [INFO] Unrecognized VM option 'PrintGCDateStamps'
2019-10-16 11:51:08.973 STDERR Thread-1 [INFO] [0.000s][warning][gc] -Xloggc is deprecated. Will use -Xlog:gc:artifacts/gc.log instead.
2019-10-16 11:51:08.977 STDERR Thread-0 [INFO] Error: Could not create the Java Virtual Machine.
2019-10-16 11:51:08.978 STDERR Thread-0 [INFO] Error: A fatal exception has occurred. Program will exit.
【问题讨论】:
标签: java apache-storm topology