Apache Storm 1.1.0 не запущен и не может прочитать дополнительные данные из клиента sessionid - PullRequest
Новая
       295

Apache Storm 1.1.0 не запущен и не может прочитать дополнительные данные из клиента sessionid

0 голосов
/ 06 мая 2019

Я использую простое приложение Hello World в Apache Storm 1.1.0.Приложение имеет случайный целочисленный носик и болт, который печатает вывод кортежа.Но почему-то я не могу заставить его работать в моей системе Windows.

Я новичок в Apache Storm и после учебника.Я искал ответы в переполнении стека, но мне не удалось найти какой-либо решенный вопрос относительно того же.

Ниже приведен мой код топологии пробега: 

public static void runTopology() {
    //String filePath = "./src/main/resources/operations.txt";
    TopologyBuilder builder = new TopologyBuilder();
    builder.setSpout("randomNumberSpout", new RandomIntSpout());
    builder.setBolt("printingBolt", new PrintingBolt()).shuffleGrouping("randomNumberSpout");

    Config config = new Config();
    config.setDebug(true);
    LocalCluster cluster = new LocalCluster();
    try{
        cluster.submitTopology("Test", config, builder.createTopology());
    }finally{
        cluster.shutdown();
    }
}

Код болта 

public class PrintingBolt extends BaseBasicBolt {

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

    public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) {
        System.out.println("Printing Tupple!!!!");
        System.out.println(tuple);
        System.out.println("Tupple processed " + tuple.getInteger(1));
        basicOutputCollector.emit(new Values(tuple.getInteger(1)));
    }

    public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
        outputFieldsDeclarer.declare(new Fields("TestOutput"));

    }
}

Код носика 

public class RandomIntSpout extends BaseRichSpout {

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

    private Random random;
    private SpoutOutputCollector outputCollector;

    /*@Override
    public void open(Map<String,Object> map, TopologyContext topologyContext,
      SpoutOutputCollector spoutOutputCollector) {
        random = new Random();
        outputCollector = spoutOutputCollector;
    }*/

    public void nextTuple() {
        Utils.sleep(1000);
        outputCollector.emit(new Values(random.nextInt(), System.currentTimeMillis()));
    }

    public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
        outputFieldsDeclarer.declare(new Fields("randomInt", "timestamp"));
    }

    public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
            random = new Random();
            outputCollector = collector;
    }
}

Я могу предоставить и остальную часть кода, но я не думаю, что это потребуется.Если необходимо, укажите это в комментариях, я также сообщу об этом.

Я получаю следующую ошибку, когда пытаюсь запустить приложение.

10620 [main] INFO oassoazZooKeeper - Инициирование соединения с клиентом, connectString= localhost: 2000 / storm sessionTimeout = 20000> watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@31b0f02 10625 [main-SendThread (0: 0: 0: 0: 0: 0: 0: 1: 2000)] INFO oassoazClientCnxn - Открытие подключения сокета к серверу> 0: 0: 0: 0: 0: 0: 0: 1/0: 0: 0: 0: 0: 0: 0: 1: 2000.Не будет пытаться аутентифицироваться с использованием SASL (неизвестная ошибка) 10627 [main-SendThread (0: 0: 0: 0: 0: 0: 0: 1: 2000)] INFO oassoazClientCnxn - Соединение с сокетом установлено в> 0: 0: 0:0: 0: 0: 0: 1/0: 0: 0: 0: 0: 0: 0: 1: 2000, инициирующий сеанс 10627 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] ИНФОРМАЦИЯ oassoazsNIOServerCnxnFactory - Принятоподключение к сокету из /> 0: 0: 0: 0: 0: 0: 0: 1: 56905 10628 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] INFO oassoazsZooKeeperServer - Клиент пытается установить новый сеанс в />0: 0: 0: 0: 0: 0: 0: 1: 56905 10631 [main-SendThread (0: 0: 0: 0: 0: 0: 0: 1: 2000)] INFO oassoazClientCnxn - Установление сеанса завершено на сервере> 0: 0: 0: 0: 0: 0: 0: 1/0: 0: 0: 0: 0: 0: 0: 1: 2000, sessionid = 0x16a8e5abd97000d, согласованное время ожидания = 20000 10631 [SyncThread: 0] INFOoassoazsZooKeeperServer - установленный сеанс 0x16a8e5abd97000d с согласованным временем ожидания 20000 для клиента /> 0: 0: 0: 0: 0: 0: 0: 1: 56905

10632 [main-EventThread] INFO oassoacfsConnectionStateManager: СОЕДИНЕННЫЙ 10635 [ProcessThread (sid: 0 cport: -1):] ИНФОРМАЦИЯ oassoazsPrepRequestProcessor - Получил KeeperException уровня пользователя при обработке sessionid: 0x16a8e5abd97000d тип: создать cxid: 0x2 zxid: 0x26 txntype: -1 reqpath: n / a Путь ошибки: шторм / хранилище: путь / штормовая последовательность> Ошибка: KeeperErrorCode = NoNode для / шторма / blobstoremaxkeysequencenumber 10655 [Куратор-Framework, 0] INFO oassoacfiCuratorFrameworkImpl - backgroundOperationsLoop выходе из 10657 [ProcessThread (SID: 0 cport: -1):] INFO oassoazsPrepRequestProcessor - Обработанные завершения сеанса для SessionID:> 0x16a8e5abd97000d 10659[main-EventThread] INFO oassoazClientCnxn - EventThread завершил работу 10659 [main] INFO oassoazZooKeeper - Сессия: 0x16a8e5abd97000d закрыта 10661 [главная] INFO oascluster - путь-установки / blobstore / Test-1-1557166474-stormC50C..com: 6627-1 10660 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] WARN oassoazsNIOServerCnxn - исключение прекращения потока в конце org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn $ EndOfStreamException: невозможно прочитать дополнительные данные из клиента sessionid> 0x16a8e5abd97000d, вероятно, клиент закрыл сокет в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO (NIOServerCnxn.java:228) [storm-core-1.1.0.jar: 1.1.0] at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run (NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar: 1.1.0] at java.lang.Thread.run (Thread.java:745) [?: 1.8.0_60] 10671 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] INFO oassoazsNIOServerCnxn - закрытое сокетное соединение для клиента />0: 0: 0: 0: 0: 0: 0: 1: 56905 с идентификатором сеанса 0x16a8e5abd97000d10746 [главная] ИНФОРМАЦИЯ o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Запуск 10747 [main] ИНФОРМАЦИЯ o.a.s.s.o.a.z.ZooKeeper - Инициирование соединения с клиентом, connectString = localhost: 2000 / storm sessionTimeout = 20000> watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@73893ec1 10755 [main-SendThread (127.0.0.1:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Открытие подключения сокета к серверу 127.0.0.1/127.0.0.1:2000. Не будет> пытаться аутентифицироваться с использованием SASL (неизвестная ошибка) 10756 [main-SendThread (127.0.0.1:2000)] INFO o.a.s.s.s.o.a.z.ClientCnxn - соединение с сокетом установлено для 127.0.0.1/127.0.0.1:2000, инициирование> сеанса 10758 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Допустимое подключение к сокету из /127.0.0.1:56908 10759 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - клиент пытается установить новый сеанс в> /127.0.0.1:56908 10766 [main-SendThread (127.0.0.1:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Установление сеанса завершено на сервере 127.0.0.1/127.0.0.1:2000,> sessionid = 0x16a8e5abd97000e, согласованное время ожидания = 20000 10766 [SyncThread: 0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - установленный сеанс 0x16a8e5abd97000e с согласованным тайм-аутом 20000 для клиента> /127.0.0.1:56908 10767 [main-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - Изменение состояния: СОЕДИНЕНО 10778 [Curator-Framework-0] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop exiting 10781 [ProcessThread (sid: 0 cport: -1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Обработанное завершение сеанса для sessionid:> 0x16a8e5abd97000e 10785 [main] ИНФОРМАЦИЯ o.a.s.s.o.a.z.ZooKeeper - Сессия: 0x16a8e5abd97000e закрыта 10785 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - Соединение с закрытым сокетом для клиента /127.0.0.1:56908>, для которого идентификатор сеанса 0x16a8e5abd97000e 10785 [main] ИНФОРМАЦИЯ o.a.s.cluster - путь установки / blobstore / Test-1-1557166474-stormcode.ser / IBMT450PC053RLV.Corp.CVS.com: 6627-1 10786 [main-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread выключен 10821 [main] INFO o.a.s.d.nimbus - желаемый счетчик репликации 1 достигнут, текущий счетчик репликации для ключа conf = 1, текущий счетчик репликации> для ключа кода = 1, текущий счетчик репликации для ключа jar = 1 11042 [main] INFO o.a.s.d.nimbus - Активация теста: Test-1-1557166474 11058 [главная] ИНФОРМАЦИЯ o.a.s.d.nimbus - Завершение работы мастера 11064 [Curator-Framework-0] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop exiting 11066 [ProcessThread (sid: 0 cport: -1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Обработанное завершение сеанса для sessionid:> 0x16a8e5abd970003 11068 [main-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread выключен 11069 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] WARN o.a.s.s.o.a.z.s.NIOServerCnxn - исключение в конце потока org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn $ EndOfStreamException: невозможно прочитать дополнительные данные из клиента sessionid> 0x16a8e5abd970003, вероятно, клиент закрыл сокет в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO (NIOServerCnxn.java:228) [storm-core-1.1.0.jar: 1.1.0] в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run (NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar: 1.1.0] на java.lang.Thread.run (Thread.java:745) [?: 1.8.0_60] 11068 [главная] ИНФОРМАЦИЯ o.a.s.s.o.a.z.ZooKeeper - Сессия: 0x16a8e5abd970003 закрыта 11069 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - Соединение с закрытым сокетом для клиента /127.0.0.1:56875>, у которого есть sessionid 0x16a8e5abd970003 11069 [Curator-Framework-0] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop exiting 11072 [ProcessThread (sid: 0 cport: -1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Обработанное завершение сеанса для sessionid:> 0x16a8e5abd97000411074 [main-EventThread] INFO oassoazClientCnxn - EventThread выключен0: 1: 56878, которые были SESSIONID 0x16a8e5abd970004 11074 [главные] INFO oassoazZooKeeper - сессия: 0x16a8e5abd970004 закрыто 11077 [Куратор-Framework, 0] INFO oassoacfiCuratorFrameworkImpl - backgroundOperationsLoop выход из 11079 [ProcessThread (SID: 0 cport: -1):] INFO oassoazsPrepRequestProcessor -Обработанное завершение сеанса для sessionid:> 0x16a8e5abd970000 11081 [main] INFO oassoazZooKeeper - Сессия: 0x16a8e5abd970000 закрыта 11081 [main] INFO oaszookeeper - закрытие соединения zookeeper ведущего избирателя.11082 [main-EventThread] ИНФОРМАЦИЯ oassoazClientCnxn - EventThread завершил работу 11082 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] ИНФОРМАЦИЯ oassoazsNIOServerCnxn - Закрытое сокетное соединение для клиента /127.0.0.1:56866>, который имел sessionid 0x0 082 05016a [0x16].-Framework-0] INFO oassoacfiCuratorFrameworkImpl - backgroundOperationsLoop, выходящий из 11084 [ProcessThread (sid: 0 cport: -1):] INFO oassoazsPrepRequestProcessor - обработанное завершение сеанса для sessionid:> 0x16a8e5abd970001 110oSee050e0e0e0e:EventThread] INFO oassoazClientCnxn - EventThread завершил работу 11087 [main] INFO oasdnimbus - завершил работу мастера 11087 [Curator-Framework-0] INFO oassoacfiCuratorFrameworkImpl - backgroundOperationsLoop выходит из режима 11089 [NIOServerCxn.Factory 0.0aznSn0.0n: 0.0: 2000: 0.0.0: 2000.0перехвачено исключение конца потока org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn $ EndOfStreamException: невозможно прочитать дополнительные данные изclient sessionid> 0x16a8e5abd970001, вероятно, клиент закрыл сокет в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO (NIOServerCnxn.java:228) [storm-core-1.1.0.jar: 1.1.0] в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run (NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar: 1.1.0] в java.lang.Thread.run (Thread.java:745) [?: 1.8.0_60] 11089 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] INFO oassoazsNIOServerCnxn - Закрытое сокетное соединение для клиента /127.0.0.1:56869>, для которого был установлен sessionid0x16a8e5abd970001 11090 [ProcessThread (sid: 0 cport: -1):] INFO oassoazsPrepRequestProcessor - обработанное завершение сеанса для sessionid:> 0x16a8e5abd970006 11092 [основной] INFO oassoazZooKeeper - сеанс: фоновая среда 0x16a2010 для рабочих мест - 0x16a8eBeBeBeOd - рабочая среда11093 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] WARN oassoazsNIOServerCnxn - перехвачено исключение конца потока org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn $ EndOfStreamException: невозможно прочитать дополнительные данные из клиента sessionid> 0x16a8e5abd970006, вероятно, клиент закрыл сокет в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxdodo(NIOServerCnxn.java:228) [storm-core-1.1.0.jar: 1.1.0] в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run (NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar: 1.1.0] на java.lang.Thread.run (Thread.java:745) [?: 1.8.0_60] 11094 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0:2000] INFO oassoazsNIOServerCnxn - Закрытое сокетное соединение для клиента /127.0.0.1:56884>, у которого был sessionid 0x16a8e5abd970006 11095 [main-EventThread] INFO oassoazClientCnxn - EventThread завершил работу 11095 [ProcessThread (sid: 0 cspor: oport: oport: oport: oport: oport: oport: opro: oport: -1):)Обработанное завершение сеанса для sessionid:> 0x16a8e5abd970008 11098 [main] INFO oassoazZooKeeper - Сессия: 0x16a8e5abd970008 закрыта11098 [main-EventThread] INFO oassoazClientCnxn - EventThread завершил работу 11099 [main] INFO oasdsReadClusterState - установил нить [SLOT_1024,5, main] для нулевого значения 11099 [main] INFO oasdsReadClusterState - установил нить [SLOT_1025,5, main] для null11099 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] WARN oassoazsNIOServerCnxn - перехвачено исключение конца потока org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn $ EndOfStreamException: невозможно прочитать дополнительные данные изclient sessionid> 0x16a8e5abd970008, вероятно, клиент закрыл сокет в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO (NIOServerCnxn.java:228) [storm-core-1.1.0.jar: 1.1.0] в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run (NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar: 1.1.0] в java.lang.Thread.run (Thread.java:745) [?: 1.8.0_60] 11099 [main] INFO oasdsReadClusterState - Установка нити [SLOT_1026,5, main] для нулевого 11099 [main] INFO oasdsReadClusterState - ожидание того, что поток [SLOT_1024,5, main] будет пустым, в настоящее время EMPTY 11099 [main] INFO oasdsReadClusterState - ожидание потока [SLOT_1025,5, main] будет пустым, в настоящее время EMPTY 11099 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0:2000] INFO oassoazsNIOServerCnxn - Закрытое сокетное соединение для клиента /> 0: 0: 0: 0: 0: 0: 0: 0: 1: 56890 с сеансом 0x16a8e5abd970008 11099 [main] INFO oasdsReadClusterState - Ожидание потока [SLOT_10, 5, main] будет EMPTY, в настоящее время EMPTY 11099 [main] INFO oasdsSupervisor - отключение супервизора 009e412c-0d39-400c-8302-08296524c703 11100 [Thread-10] INFO oaseEventManagerImp - менеджер событий прерван 11102 [Curator-Framework-0]ИНФО oassoacfiCuratorFrameworkImpl - backgroundOperationsLoop выход из 11103 [ProcessThread (SID: 0 cport: -1):] INFO oassoazsPrepRequestProcessor - Обработанные завершения сеанса для SessionID:> 0x16a8e5abd97000a 11105 [главный] INFO oassoazZooKeeper - сессия: 0x16a8e5abd97000a закрыто 11105 [главного] INFO oasdsReadClusterState - Setting Тема [SLOT_1027,5, main] присваивается нулевое 11105 [main-EventThread] ИНФОРМАЦИЯ oassoazClientCnxn - EventThread завершает работу 11105 [main] INFO oasdsReadClusterState - Настройка потока [SLOT_1028,5, main] присваивается нулевому 11105 [main] INFO oasdsReadStateУстановка для потока [SLOT_1029,5, main] нулевого значения 11106 [main] INFO oasdsReadClusterState - ожидание того, что Thread [SLOT_1027,5, main] будет пустым, в настоящее время EMPTY 11106 [main] INFO oasdsReadClusterState - ожидание потока [SLOT_1028,5,main] будет EMPTY, в настоящее время EMPTY 11106 [main] INFO oasdsReadClusterState - ожидание того, что Thread [SLOT_1029,5, main] будет EMPTY, в настоящее время EMPTY 11106 [main] INFO oasdsSupervisor - отключение супервизора 5daf8496-451f-43ca-b17618160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160160660111106 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] WARN oassoazsNIOServerCnxn - перехвачено исключение конца потока org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn $ EndOfStreamException: невозможно прочитать дополнительные данные из дополнительных данных:ID сеанса клиента> 0x16a8e5abd97000a, likely клиент закрыл сокет в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO (NIOServerCnxn.java:228) [storm-core-1.1.0.jar: 1.1.0] в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run (NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar: 1.1.0] в java.lang.Thread.run (поток.java: 745) [?: 1.8.0_60] 11106 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] INFO oassoazsNIOServerCnxn - Соединение с закрытым сокетом для клиента /> 0: 0: 0: 0: 0: 0: 0: 1: 56896 с сеансом 0x16a8e5abd97000a 11106 [Thread-14] INFO oaseEventManagerImp - Менеджер событий прерван 11108 [Curator-Framework-0] INFO oassoacfiCuratorFrameworkImpl - backgroundOperationsLoop exiting11109 [ProcessThread (sid: 0 cport: -1):] INFO oassoazsPrepRequestProcessor - Обработанное завершение сеанса для sessionid:> 0x16a8e5abd97000c 11112 [основной] INFO oassoazZooKeeper - сеанс: 0x16a8e5abd97000c закрыт 11112 [событие-главный объект - закрыто 11112 [событие-главный объект] - событие-основной объект - событие-mainCoN EventOnCoOnOnOnOnCoOnOnOnCoOnOnOcOnOnOcOnOnOcOnOnOnCoOnOnOcOnOnOcOnOnOcOnOcOnOnOcOnOnO - Кроме того, событие закрыто.NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] WARN oassoazsNIOServerCnxn - обнаружена исключительная ситуация конца потока org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn $ EndOfStreamException: невозможно прочитать дополнительные данные из сеанса клиента> 0x16a8e5abd97000c, вероятно, клиент закрыл сокет в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO (NIOServerCnxn.java:228) [storm-core-1.1.0.jar: 1.1.0]в org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run (NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar: 1.1.0] в java.lang.Thread.run(Thread.java:745) [?: 1.8.0_60] 11113 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] INFO oassoazsNIOServerCnxn - Соединение с закрытым сокетомction для клиента /127.0.0.1:56902>, который имел sessionid 0x16a8e5abd97000c 11114 [main] oastesting INFO - Завершение работы в zookeeper процесса 11115 [NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2000] INFO oassoazsNIOServernnnNexsernnNNExserverNNX11116 [главная] INFO oassoazsZooKeeperServer - выключение 11116 [главная] INFO oassoazsSessionTrackerImpl - выключение 11116 [главная] INFO oassoazsPrepRequestProcessor - выключение 11117 [главная] INFO oassoazsSyncRequestSyncProcessOscorSecureSecrecessOscorSecureSecrequest11117 [ProcessThread (sid: 0 cport: -1):] ИНФОРМАЦИЯ oassoazsPrepRequestProcessor - цикл PrepRequestProcessor завершен!11117 [main] INFO oassoazsFinalRequestProcessor - завершение работы процессора запросов 11118 [main] INFO oastesting - Завершение работы в процессе zookeeper 11118 [main] INFO oastesting - удаление временного пути C: \ Users \ AKHAND ~ 1 \ AppData \ Local \ Temp \ae4119b4-70b3-4d04-9aee-5bfae4c4775b 11203 [main] oastesting INFO - удаление временного пути C: \ Users \ AKHAND ~ 1 \ AppData \ Local \ Temp \ a78b8c79-b9b3-438d-8df6-5d7bd74281fc 11215 main] INFOНевозможно удалить файл:> C: \ Users \ AKHAND ~ 1 \ AppData \ Local \ Temp \ a78b8c79-b9b3-438d-8df6-5d7bd74281fc \ version-2 \ log.1 11215 [main] oastesting INFO - удаление временного пути C:\ Users \ AKHAND ~ 1 \ AppData \ Local \ Temp \ 0e4fbadc-ad33-4577-9784-4cc163a778fa 11255 [main] oastesting INFO - удаление временного пути C: \ Users \ AKHAND ~ 1 \ AppData \ Local \ Temp \ 456d6b1d-eb21-4b76-98f1-a2bb44b2aa5e 12197 [SessionTracker] INFO oassoazsSessionTrackerImpl - выходной цикл SessionTrackerImpl!

Я не могу понять, почему клиентский сокет закрыт и почему sessioп закрыто?Я не могу заставить его работать.Пожалуйста, помогите.

1 Ответ

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

Я думаю, вам может понадобиться добавить сон 

try{
        cluster.submitTopology("Test", config, builder.createTopology());
        //Sleep here
    }finally{
        cluster.shutdown();
    }

В настоящее время вы отправляете топологию и немедленно завершаете работу. Если вы не поспите, ваша топология не сможет работать.

...