尝试在本地storm docker容器上提交streamparse wordcount示例

jdgnovmf  于 2021-06-24  发布在  Storm
关注(0)|答案(0)|浏览(306)

我正在尝试在带有docker容器的本地集群上使用streamparse
这是我的docker-compose.yml version: '3' services: zookeeper: image: zookeeper container_name: zookeeper nimbus: image: storm:1.0.2 container_name: nimbus command: storm nimbus depends_on: - zookeeper supervisor: image: simsimy/docker-storm-supervisor-with-streamparse container_name: supervisor command: storm supervisor depends_on: - nimbus - zookeeper storm-ui: image: storm:1.0.2 container_name: storm-ui command: storm ui depends_on: - nimbus - zookeeper - supervisor streamparse示例是现成的(使用“稀疏快速启动wordcount”命令创建)
我刚刚更改了wordcount快速启动示例中的一些参数,以匹配我的storm版本1.0.2(在project.clj文件中)
顺便说一句,如果你有任何其他风暴版本的解决方案,我可以改变我的
这是我的config.json: { "serializer": "json", "topology_specs": "topologies/", "virtualenv_specs": "virtualenvs/", "envs": { "prod": { "user": "", "ssh_password": "", "nimbus": "localhost", "workers": ["localhost"], "log": { "path": "", "max_bytes": 1000000, "backup_count": 10, "level": "info" }, "use_virtualenv": true, "virtualenv_root": "/home/myhome/virtualenvs" } } } ./wordcount/virtualenvs/wordcount.txt仅包含“steamparse”(现成的配置文件)
当我运行sparse submit时,拓扑失败并显示以下消息: java.io.IOException: Cannot run program "/home/myhome/virtualenvs/wordcount/bin/streamparse_run" (in directory "/data/supervisor/stormdist/wordcount-10-1529168923/resources") 我已经检查了/data/supervisor/stormdist/wordcount-10-1529168923/resources目录,它只包含喷口和螺栓。。。
只有当我设置“use\u virtualenv”:false时,拓扑才能工作
以下是依赖项集合的日志文件:https://pastebin.com/tf48kpbb
任何帮助都将不胜感激
谢谢

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题