Многоязыковая проблема Apache Storm - PullRequest
Новая
       7

Многоязыковая проблема Apache Storm

0 голосов
/ 05 июля 2018

у нас запущена топология шторма на Java. Есть болт, который использует скрипты Python. Для этого мы используем Multilang (ShellBolt). Когда происходит перебалансировка в топологии, мы видим ошибку ниже, 

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

Это код, который вызывает модель Python 

public pythoncallBolt(String pythonpath, String pythonfilepath) {
        super(pythonpath,pythonfilepath);

    }

Пожалуйста, помогите нам решить эту проблему

...