【问题标题】:Storm Topology not Executing in ClusterStorm 拓扑不在集群中执行
【发布时间】: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


    【解决方案1】:

    已修复,应该是java版本的差异。

    目标storm集群java版本是11,我开发topo的dev环境java版本是8,导致问题。

    调整java版本,使它们相同修复问题

    【讨论】:

      【解决方案2】:

      这个问题在 2.3.0 的官方 docker 镜像中仍然存在。让主管们覆盖worker.childopts:

      docker run -d --restart always --name storm-supervisor --link storm-zk:zookeeper --link storm-nimbus:nimbus storm storm supervisor -c worker.childopts=-Xmx2048m
      

      【讨论】:

        猜你喜欢
        • 2021-06-02
        • 1970-01-01
        • 1970-01-01
        • 2015-08-06
        • 2018-04-22
        • 1970-01-01
        • 1970-01-01
        • 2015-12-01
        • 2013-05-10
        相关资源
        最近更新 更多