Tag: Watermark

Mar 02, 2026

• Flink
• 时间语义
• Watermark
• EventTime
• ProcessingTime
• 乱序数据
• 迟到数据
• 实战

Mar 02, 2026

• Flink
• Watermark
• 事件时间
• 时间语义
• Timer
• InternalTimerService
• Key-Group
• Watermark传播

Feb 28, 2026

• Spark
• Structured-Streaming
• 流处理
• 实时计算
• Watermark
• 有状态算子

Feb 28, 2026

• Spark
• Structured-Streaming
• 输出模式
• Append
• Update
• Complete
• 聚合
• Watermark

Feb 28, 2026

• Spark
• Structured-Streaming
• Watermark
• 事件时间
• 乱序数据
• 延迟数据
• 水位线
• 窗口
• State清理

Feb 28, 2026

• Spark
• Structured-Streaming
• 流-流Join
• Stream-Stream-Join
• Watermark
• Join-Buffer
• State-Store
• 时间对齐

Feb 28, 2026

• Spark
• Structured-Streaming
• dropDuplicates
• 去重
• Exactly-once
• Watermark
• State-Store
• 幂等

Feb 28, 2026

• Spark
• Structured-Streaming
• 监控
• 可观测性
• StreamingQueryListener
• Metrics
• Spark-UI
• Watermark
• 告警
• Prometheus

Feb 28, 2026

• Spark
• Structured-Streaming
• Watermark
• TTL
• 状态过期
• GroupState
• dropDuplicates
• 事件时间

Feb 28, 2026

• Spark
• 容错
• 生产调优
• 故障诊断
• Task失败
• Stage回滚
• State-Store-OOM
• Watermark
• FetchFailedException