Топология шторма не выполняется в кластере - PullRequest
Новая
       49

Топология шторма не выполняется в кластере

0 голосов
/ 16 октября 2019

отправить мой топо через stormsubmitter.submittopoloy. можно видеть топологию в интерфейсе шторма, но выбрасываемое число всегда равно 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.

1 Ответ

0 голосов
/ 16 октября 2019

исправлено, должна быть разница в версии Java.

целевой java-версией кластера штормов - 11. Моя версия java среды разработки для разработки topo - 8, что вызвало проблему.

измените версию java, чтобы они одинаково решали проблему

...