可以通过降低restratstrategy的统计灵敏度,短时间持续出现同个异常导致的failed只会计数一次,目前已经有相关patch,具体可看: https://issues.apache.org/jira/browse/FLINK-26315 <https://issues.apache.org/jira/browse/FLINK-26315>
> 2022年3月2日 下午4:35,Yang Wang <danrtsey...@gmail.com > <mailto:danrtsey...@gmail.com>> 写道: > > Standalone Flink on K8s 和 native K8s都会有你说的这个问题 > > 主要原因是标准输出打印到的pod console了,所以通过kubectl logs可以查看stdout日志,但webUI上就没有 > > 你可以参考这个commit[1]自己编译一个Flink binary来实现 > > [1]. > https://github.com/wangyang0918/flink/commit/2454b6daa2978f9ea9669435f92a9f2e78de357a > > <https://github.com/wangyang0918/flink/commit/2454b6daa2978f9ea9669435f92a9f2e78de357a> > > Best, > Yang > > > xinzhuxiansheng <xinzhuxiansh...@126.com> 于2022年3月2日周三 15:00写道: > >> Flink on Native k8s部署后,程序答应的log,无法在Flink UI TaskManager的查看到日志。 不太想ELK方式收集 >> TaskManager 日志。 若使用kubectl logs查看pod的标准化输出对用户来说太复杂了。请问大家是如何处理的? >> >> >> | | >> xinzhuxiansheng >> | >> | >> xinzhuxiansh...@126.com >> | >> 签名由网易邮箱大师定制 >> >>