Запуск Apache Storm в локальном режиме ошибки подключения - PullRequest
Новая
       30

Запуск Apache Storm в локальном режиме ошибки подключения

1 голос
/ 18 мая 2019

РЕДАКТИРОВАТЬ: Таким образом, это "решено", когда я увеличиваю время ожидания, но все еще получаю ошибки соединения / тайм-аута 

59297 [Thread-14] ERROR o.a.s.d.s.ReadClusterState - Failed to Sync Supervisor

вот моя пользовательская топология: 

public class MyTopology {
    public static void main(String[] args) {
        TopologyBuilder builder = new TopologyBuilder();
        builder.setSpout("NameSpout", new NameSpout());
        builder.setBolt("NameBolt", new MyBolt()).shuffleGrouping("NameSpout");

        Config config = new Config();
        config.setDebug(true);
        config.setNumWorkers(1);

        LocalCluster cluster = new LocalCluster();

        try {

            cluster.submitTopology("TryingOne", config, builder.createTopology());
            Thread.sleep(10000);
        } catch (Exception e) {
            e.printStackTrace();

        } finally {
            cluster.shutdown();
        }

    }

}

1 Ответ

1 голос
/ 18 мая 2019

Да, LocalCluster позаботится об этом.Вы не должны запускать собственный сервер Zookeeper при использовании LocalCluster.

Чтобы исключить проблемы в среде, в которой вы работаете, попробуйте проверить и запустить эту топологию https://github.com/apache/storm/blob/v1.2.2/examples/storm-starter/src/jvm/org/apache/storm/starter/ExclamationTopology.java.

Если это работает, это будет проблемой с конфигурацией вашего проекта.Если нет, то, вероятно, проблема в среде, в которой вы находитесь.

...