算子探查（公測）
算子探查功能可以在不修改作業(yè)的情況下看到中間結(jié)果的輸出，降低排查數(shù)據(jù)正確性錯誤的難度，提高人效和業(yè)務(wù)的連續(xù)性，減少重點實時業(yè)務(wù)的中斷時間。本文為您介紹如何進行算子探查。
背景信息
Flink作業(yè)運維時，會遇到產(chǎn)出結(jié)果不符合預(yù)期的情況，這類問題常稱為數(shù)據(jù)正確性問題。數(shù)據(jù)正確性問題的產(chǎn)生原因復(fù)雜且不易定位，常見的解決方法是將SQL作業(yè)進行邏輯拆解，通過Print連接器打印每一步的結(jié)果，對數(shù)據(jù)結(jié)果進行分析，找到可能的原因。這個處理流程不僅耗費時間精力，而且可能因為測試數(shù)據(jù)與線上數(shù)據(jù)或者State不一致導(dǎo)致無法排查到原因。因此，此類問題的解決常需要很長的時間，并進行多次作業(yè)啟停。實時計算Flink版提供了算子探查功能，可以在不修改作業(yè)的情況下，探查選中算子的輸入輸出情況，幫助您更好地排查數(shù)據(jù)正確性問題。
使用限制
僅支持運行中的SQL作業(yè)。
僅支持實時計算引擎VVR 8.0.4及以上版本作業(yè)。
不支持CTAS、CDAS作業(yè)。
不支持部署到Session集群的作業(yè)。
在探查沒有停止前，無法再次進行探查。
操作步驟
登錄實時計算控制臺，單擊目標(biāo)工作空間操作列下的控制臺。
在左側(cè)導(dǎo)航欄上，選擇。
單擊目標(biāo)作業(yè)名稱，單擊狀態(tài)總覽頁簽。
開啟算子探查。
打開算子探查開關(guān)。
單擊需要進行探查的算子，支持選擇多個算子。
設(shè)置最大采樣時間。
支持設(shè)置1～30min的采樣時間，采樣過程中如果達到最大存儲上限會提前終止采樣。
單擊開始探查。探查狀態(tài)變更為采樣中。
說明在探查沒有停止前，無法再次進行探查。
查看探查結(jié)果。
您可以單擊提示中的TM 日志列表進入到運行日志頁面，查看Log Name為inspect-taskmanager_0.out的日志。
結(jié)果展示如下。您可以在狀態(tài)總覽頁簽的DAG圖中復(fù)制算子名稱，在日志頁面搜索查看具體算子的輸出。
探查停止方式
作業(yè)發(fā)生failover后自動停止（JM & TM）。
達到最大存儲上限會提前終止采樣。
達到采樣時間后停止。
手動停止探查。