2017-04-03 26 views

回答

0

Flink作业的输出将写入TaskManager的标准输出。

编辑:作业完成时:纱线,你可能会使用聚合YARN日志(yarn logs -applicationId <appid>)检索所有日志,如果你已经启用了访问该输出。

一个快速和肮脏的解决方案是例如发送您的输出在接收器插座。

+1

直到工作完成后才能使用。 – Sohi

+0

对于YARN日志你是对的,对于标准输出或接收器插座它的工作原理。 – ImbaBalboa

1

那么在YARN上运行时没有直接的方法来检查日志。

我找到了另一种方法。我已将Flink Rolling Sink添加到正在使用YYYY-mm-dd - HH 格式将日志写入hdfs位置的流式作业中。

除此之外,创建配置单元表查询日志。