Flink1.2 Flink on yarn
在运行./bin/flink run ./examples/streaming/TopSpeedWindowing.jar Demo的时候总是报
org.apache.flink.util.FlinkException: Could not retrieve file from transient
无法从暂态检索文件
以下是我的报错信息
我的Flink yaml配置文件中io.tmp.dirs配置项是tmp/flink
后来上网查找了一大顿资料还是没有头绪。按照我是菜鸟的经验来告诉我,如果这个思路网上都没有相应答案的话,那就是我错了。
后来我仔细阅读官网,和相应Flink on yarn的文档,恍然大明白,以下是参考资料
官网资料
原来我靠,start-cluster.sh 之后不能再
执行这个yarn-session.sh --detached了
./bin/yarn-session.sh --detached
就算执行成功,运行也会报之前的错,只能运行一种模式,fuck。
然后把所有的FlinK进程都关闭了之后
就是执行stop-cluster.sh
杀掉yarn上面的yarn seesion cluster进程
总之所有的Flink进程都停掉重新来
加上一个配置我也不知道有没有用
全部杀掉后
就按照官网执行
./bin/yarn-session.sh --detached
这个指令。start-cluster.sh不用执行
然后执行./bin/flink run ./examples/streaming/TopSpeedWindowing.jar
这个官网demo
终于成功了
流弊!!!!!!!!!!!!!!skr skr skr
因篇幅问题不能全部显示,请点此查看更多更全内容
Copyright © 2019- hids.cn 版权所有 赣ICP备2024042780号-1
违法及侵权请联系:TEL:199 1889 7713 E-MAIL:2724546146@qq.com
本站由北京市万商天勤律师事务所王兴未律师提供法律服务