1

设置：

  • 风暴 0.10.0
  • 流解析 2.1.4
  • 森托斯 6.5
  • Python 2.7（Streamparse 需要它）

（是的，我知道它们已经过时了，但是我无法使用 Storm 1.0，它只是被 streamparse 3 破坏了）

当我尝试从我的 nimbus 服务器或拓扑中的另一台服务器启动“streamparse submit”时，我收到以下错误：

“IOError：本地端口：6627 已在使用中，无法打开到 nimbus.server.local:6627 的 ssh 隧道。”

但是当然 6627 正在我的 nimbus 服务器上使用？它的 Thrify 端口。所以我尝试将 Thrifty 端口移动到 6637 并重新启动 Nimbus。但是我从提交它的客户那里得到了同样的错误：

IOError：本地端口：6627 已在使用中，无法打开到 nimbus.server.local:6627 的 ssh 隧道。

即使是 netstat tuanp 也显示 6627 表明在 nimbus 上的该端口或执行提交的盒子上没有任何东西在监听。

我感觉与 SSHD 配置和允许隧道有关，但 Nimbus 没有正确处理，并且在尝试建立隧道时给出了不正确的错误。

有没有其他人经历过这个？

4

2 回答 2

0

运行风暴拓扑时我遇到了同样的错误。

我做了以下更改，然后效果很好，添加了以下属性

在 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 *

并提交为“稀疏提交”请让我知道，如果它有效，或者分享配置文件

于 2016-07-19T11:06:43.710 回答
0

这就是我最终在本地 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

于 2016-05-01T18:36:13.763 回答