2017-04-03 44 views

回答

0

Flink作業的輸出將寫入TaskManager的標準輸出。

編輯:作業完成時:紗線,你可能會使用聚合YARN日誌(yarn logs -applicationId <appid>)檢索所有日誌,如果你已經啓用了訪問該輸出。

一個快速和骯髒的解決方案是例如發送您的輸出在接收器插座。

+1

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

+0

對於YARN日誌你是對的,對於標準輸出或接收器插座它的工作原理。 – ImbaBalboa

1

那麼在YARN上運行時沒有直接的方法來檢查日誌。

我找到了另一種方法。我已將Flink Rolling Sink添加到正在使用YYYY-mm-dd - HH 格式將日誌寫入hdfs位置的流式作業中。

除此之外,創建配置單元表查詢日誌。