streamparse:ioerror:本地端口:6627已在使用中,无法打开到nimbus.server的ssh隧道local:6627

pb3skfrl  于 2021-06-21  发布在  Storm
关注(0)|答案(2)|浏览(398)

设置:
风暴0.10.0
流程分析2.1.4
centos 6.5版
Python2.7(streamparse需要它)
(是的,我知道它们已经过时了,但是我无法使用storm 1.0,它刚刚被streamparse 3破坏)
当我尝试从我的nimbus服务器或拓扑中的另一个服务器启动“streamparse submit”时,出现以下错误:
“ioerror:本地端口:6627已在使用中,无法打开到nimbus.server的ssh隧道。local:6627."
当然6627在我的nimbus服务器上使用了?这是第三个港口。所以我试着把thrifty港口移到6637重新启动nimbus。但是我从提交的客户那里得到了同样的错误:
ioerror:本地端口:6627已在使用中,无法打开到nimbus.server的ssh隧道。local:6627.
甚至一个netstat tuanp也显示6627没有监听nimbus上的端口或执行submit的盒子。
我觉得sshd config和允许隧道有关,而nimbus没有正确处理这个问题,并且在尝试建立隧道时给出了错误的错误。
还有其他人经历过吗?

4c8rllxm

4c8rllxm1#

我在运行storm topology时也遇到了同样的错误。
我做了以下更改,然后工作正常,添加了以下属性
在config.json中,

"use_ssh_for_nimbus": false,
        "use_virtualenv": false,

在fabfile.py中,

from fabric.api import env
        env.use_ssh_config = False
        env.password = '****'
        from streamparse.ext.fabric import *

并提交为“稀疏提交”请让我知道,如果它工作,或共享配置文件

dwbf0jvd

dwbf0jvd2#

这就是我在本地storm集群中部署streamparse storm拓扑所做的:

> sparse quickstart quickstart-2.1.4
> cd quickstart-2.1.4
> sparse jar
> storm jar _build/quickstart-2.1.4-0.0.1-SNAPSHOT-standalone.jar streamparse.commands.submit_topology topologies/wordcount.clj

这适用于streamparse 2.1.4和storm 0.9.5

相关问题