Python中文
首页
教程
问答
标签
搜索
登录
注册
apachebeam Python单词计数示例对于使用bemioe的Flink Runner失败
回答此问题可获得
20
贡献值,回答如果被采纳可获得
50
分。
<p>我尝试在Apache的Flink上运行apachebeam Python单词计数示例,使用PortableRunner,通过Docker使用SDK-harness/Job服务器。在</p> <ol> <li><p>使用<code>./gradlew -p sdks/python/container docker</code>生成了SDK线束容器。但是在对创建的图像进行docker pull时,会出现以下错误:</p> <blockquote> <p>Using default tag: latest Error response from daemon: Get https://$userId-docker- apache.bintray.io/v2/: x509: certificate is valid for *.bintray.io, bintray.io, not $userId-docker- apache.bintray.io</p> </blockquote></li> <li><p>使用<code>./gradlew beam-runners-flink_2.11-job-server:runShadow</code>成功启动Flink portable Jobservice终结点。</p></li> </ol> <p>但是当尝试使用下面的命令和PortableRunner一起运行wordcount示例时</p> <pre><code>python -m apache_beam.examples.wordcount --input=local_input_file --output=local_output_file --job_endpoint=localhost:8099 --experiments beam_fn_api --runner=PortableRunner </code></pre> <p>它给出以下错误:</p> <blockquote> <p>IOError as “RuntimeError: IOError: [Errno 2] No such file or directory: '/beam-temp-output-b6d55cb671ef11e9be2f025000000001/3ce015aa-78ee-4bfa-be17-120de259e690.output' [while running 'write/Write/WriteImpl/FinalizeWrite’]”</p> </blockquote> <p>用DirectRunner而不是PortableRunner运行可以让它工作得很好! 任何关于我如何通过Docker让wordcount与PortableRunner一起工作的提示,我们将不胜感激。在</p>
0 条评论
分类:
Python问答
请先
登录
后评论
默认排序
时间排序
1 个回答
匿名
1天前
擅长:python、mysql、java
<p>您是否尝试指定存储库名称并从中提取?(通过使用-Pdocker repository root)</p> <p>像这样:</p> <p>“/gradlew-Pdocker存储库根目录”=gcr.io/此处有姓名-p SDK/go/集装箱码头工人”</p>
请先
登录
后评论
针对此问题:
更多的回答
关注
89
关注
收藏
1
收藏,
216
浏览
网友 提问于 2天前
相关Python问题
如何添加虚拟方法
10 回答
如何添加表示整数的擦边字符串?
10 回答
如何添加要在Bokeh中使用的新font.ttf文件?
4 回答
如何添加要显示的矩阵XY轴编号和XY轴
10 回答
如何添加计数?
2 回答
如何添加计数器函数?
6 回答
如何添加计数器列来计算数据帧中另一列中的特定值?
2 回答
如何添加计数器来跟踪while循环中的月份和年份?
1 回答
如何添加计数并删除countplot的顶部和右侧脊椎?
9 回答
如何添加计时器wx.应用程序更新窗口对象的主循环?
9 回答
如何添加评论到帖子?PostDetailVew,Django 2.1.5
5 回答
如何添加评论拉梅尔亚姆
2 回答
如何添加诸如矩阵Python/Pandas之类的数据帧?
6 回答
如何添加谷歌地点自动完成到Flask?
3 回答
如何添加超时、python discord bot
10 回答
如何添加超过1dp的检查
1 回答
如何添加距离方法
2 回答
如何添加跟随游戏的敌人精灵
3 回答
如何添加路径以便python可以找到程序?
4 回答
如何添加身份验证/安全性以使用happybase访问HBase?
10 回答