升级过程将会更新 Spark 应用程序相关文件。要使用更新文件,您必须重启 Spark 作业,重设置与 Kafka 主题相关的所有 Spark 检查点。要防止数据因重设置 Kafka 主题检查点而丢失,您必须在升级 SSDM 之前,暂停将数据从 Collector Manager 转发到 Kafka。暂停转发数据之后,数据将储存在 Collector Manager 上,直到恢复数据转发。Spark 应用程序处理完转发暂停前转发到 Kafka 的数据后,可安全重设置检查点,不会丢失数据。
要暂停将事件从 Collector Manager 转发至 Kafka:
在 Sentinel 主界面,单击储存 > 可缩放储存 > 高级配置 > Kafka。
添加以下属性,并将其设置为 true:
pause.events.tokafka
单击保存。