流式水印提升策略具有以下限制:
MAX_NOT_SUPPORTED_IN_RTM
在流式处理实时模式下不支持 MAX 水印提升策略。
若要继续执行实时模式,请将 spark 会话配置“spark.databricks.streaming.watermarkAdvancementStrategy”设置为“min”。
MIN_NOT_SUPPORTED_IN_MBM
流式微批处理模式不支持 MIN 水印推进策略。
若要继续进行微批处理模式,请将 spark 会话配置“spark.databricks.streaming.watermarkAdvancementStrategy”设置为“max”。