Streamparse 3.14 выпуск msgpack - PullRequest
Новая
       10

Streamparse 3.14 выпуск msgpack

0 голосов
/ 18 октября 2018

При отправке топологии с использованием streamparse с msgpack serialize появляется следующая ошибка.Приведенный ниже файл config.json и трассировка стека показывают то же самое при работе в кластере HDP 2.6.5 с штормовой версией 1.1.0 и streamparse версией 3.14 и python 2.7 

{
    "serializer": "msgpack",
    "topology_specs": "topologies/",
    "virtualenv_specs": "virtualenvs/",
    "envs": {
        "prod": {
            "user": "ssh_user",
            "ssh_password": "ssh_password",
            "nimbus": "nimbus_ip",
            "workers": ["storm1","storm2","storm3"],
            "log": {
                "path": "/var/log/storm/streamparse",
                "max_bytes": 1000000,
                "backup_count": 10,
                "level": "info"
            },
            "virtualenv_root": "/data/virtualenvs"
        }
    }
}

Я получаю следующую ошибку: 

java.lang.RuntimeException:  
org.apache.storm.multilang.NoOutputException: Pipe to subprocess seems    
to be broken! No output read. Serializer Exception.
...