无法使用streamParse“ thriftpy.thrift.TApplicationException：内部错误处理beginFileUpload”提交拓扑]

Question

我正在尝试使用以下方式将拓扑提交到远程ubuntu计算机：>

sparse submit命令

并出现以下错误

  File "...../bin/sparse", line 11, in <module>
    load_entry_point('streamparse==4.0.0', 'console_scripts', 'sparse')()
  File ".../lib/python3.6/site-packages/streamparse-4.0.0-py3.6.egg/streamparse/cli/sparse.py", line 85, in main
    args.func(args)
  File "../lib/python3.6/site-packages/streamparse-4.0.0-py3.6.egg/streamparse/cli/submit.py", line 391, in main
    active=args.active,
  File "../lib/python3.6/site-packages/streamparse-4.0.0-py3.6.egg/streamparse/cli/submit.py", line 295, in submit_topology
    remote_jar_path = _upload_jar(nimbus_client, local_jar_path)
  File "../lib/python3.6/site-packages/streamparse-4.0.0-py3.6.egg/streamparse/cli/submit.py", line 158, in _upload_jar
    upload_location = nimbus_client.beginFileUpload()
  File "../lib/python3.6/site-packages/thriftpy-0.3.9-py3.6-macosx-10.9-x86_64.egg/thriftpy/thrift.py", line 198, in _req
    return self._recv(_api)
  File "../lib/python3.6/site-packages/thriftpy-0.3.9-py3.6-macosx-10.9-x86_64.egg/thriftpy/thrift.py", line 215, in _recv
    raise x
thriftpy.thrift.TApplicationException: Internal error processing beginFileUpload
我也曾尝试授予对远程计算机中安装的风暴的根访问权限

这是我的配置

{
    "serializer": "json",
    "topology_specs": "topologies/",
    "virtualenv_specs": "virtualenvs/",
    "envs": {
        "prod": {
            "user": "abc",
            "ssh_password": "abc",
            "nimbus": "ip.ip.ip.ip",
            "workers": ["ip.ip.ip.ip"],
            "log": {
                "path": "",
                "max_bytes": 1000000,
                "backup_count": 10,
                "level": "debug"
            },
            "options": {
                "virtualenv_flags": "-p /usr/bin/python3.6",
                "supervisor.worker.timeout.secs" : 1800

            },
            "virtualenv_root": "/home/abc/virtualenvs",
            "use_ssh_for_nimbus": true

            }
        }
}

我正在尝试使用稀疏提交命令将拓扑提交给远程ubuntu机器，并在load_entry_point（'...

Answer 1

这里的问题是要向其提交拓扑的ip是非领导者主管。风暴仅在Leader Leader节点上接受拓扑提交]