回复：suwei 发表于 2021-3-24 16:04 直接拿开源的Flink 1.12来提交任务到 FI 的yarn上是不可取的，我们的Flink版本有很多适配 Yarn 的改造，开源版本的Flink 1.12.0你好，我看了一下我们公司FIC80的管理界面，没找到flink的服务：

你好，我是不是可以理解不能用开源版本的flink，只能使用FIC80提供的 FLINK 1.10版本才可以

专家还在策马奔腾的路上啊

楼主，你是怎么在华为认证环境下跑通的，我目前卡在FLINK提交作业到yarn这一步，求助：https://bbs.huaweicloud.com/forum/thread-115981-1-1.html

专家，请问Flink如何通过华为FIC80的认证，我目前一直卡在认证上面，也在论坛上发求助贴了，受累看下我的求助帖：https://bbs.huaweicloud.com/forum/thread-115981-1-1.html

评论 suwei：你好，我整理了部分代码在附件中，项目中用到了一些自己打包的fi-c80 的包，经过整理已经可以开箱即用

你好，我整理了部分代码在附件中，项目中用到了一些自己打包的fi-c80 的包，经过整理已经可以开箱即用

你好，我整理了部分代码在附件中，项目中用到了一些自己打包的fi-c80 的包，经过整理已经可以开箱即用“启动类在start包下：测试时我们需要修改environment枚举类的类型，来对应我们自己的集群环境：这里我们举例先来访问CDH570环境：此时运行了一个Flink作业：作业id对应枚举类的id：此时运行程序：可以看到可以获取到了yarn上Flink的运行日志并且打印了rest api访问的路径，点击打印的url，直接跳转到了浏览器查看日志：证明路径访问正确，在代码层面，我们是拼接yarn日志访问路径，再通过http请求访问的：下面测试fi-c80,fi 正在运行一个spark作业：我们将作业id 和枚举类对应：点击测试后发现异常：SSL ，发现fi是https访问，故出现异常，从日志中看出，kerberos都成功了，这是目前遇到的问题，求助项目在附件，开箱即用

感谢解答，yarn logs 命令是可以获得运行状态，不过我们目前的需求是获取运行时作业的 日志； 比如一个作业运行一天，他的聚合日志只有任务运行结束后才可以获取，我们需要在运行的过程中，获取此作业的日志； 之前我们是通过rest api 访问开源版本的hadoop，是可以获取成功的， 现在发现FI是 https ，就访问不了，所以核心问题还是在于能否在作业运行期间获取日志

感谢解答，yarn logs 命令是可以获得运行状态，不过我们目前的需求是获取运行时作业的 日志；比如一个作业运行一天，他的聚合日志只有任务运行结束后才可以获取，我们需要在运行的过程中，获取此作业的日志；之前我们是通过rest api 访问开源版本的hadoop，是可以获取成功的， 现在发现FI是 https ，就访问不了，所以核心问题还是在于能否在作业运行期间获取日志