升級程序將會更新 Spark 應用程式的相關檔案。若要使用更新的檔案,您必須重新啟動 Spark 工作並重設 Kafka 主題上的所有 Spark 檢查點。若要避免因重設 Kafka 主題檢查點而遺失資料,您必須先暫停將資料從 Collector Manager 轉遞至 Kafka,然後再升級 SSDM。資料轉遞暫停後,資料將會儲存在 Collector Manager,直到恢復資料轉遞。當 Spark 應用程式處理好在轉遞暫停前轉遞至 Kafka 的資料時,檢查點即可安全地進行重設,而不會遺失任何資料。
若要暫停從 Collector Manager 轉遞事件至 Kafka:
在 Sentinel 主要介面上,按一下「儲存」>「可擴充儲存」>「進階組態」>「Kafka」。
加入下列內容並將其設定為 true:
pause.events.tokafka
按一下「儲存」。