第32篇流处理证据

环境：Python 3.12.3；TMPDIR/TMP/TEMP在examples/distributed-systems/.build/stream32/tmp。
研究：Dataflow VLDB 2015、Flink snapshot论文、Flink 2.3官方Time/Stateful Processing/Back Pressure。论断账本见writing-plans/distributed-systems/research/32-stream-processing.md。

实验：正式运行exit 0；--help 0；--scenario unknown 2。
源码SHA-256：aa2e45c5a1c53e98bad7d8d3187879f51e3f5158726cd55d0de340e949171e0d。
JSON SHA-256：8663a5e47e109a0e0c049e7d21f37ea2e42f0791b5e1e01a62a745e5aceb31a0。
零lateness把ts=4送入too-late并在watermark推进后清理窗口；lateness=3产生late-update，终态只保留尚未到清理阈值的窗口。checkpoint位点与重放后位点分别为1和2，managed count=2，外部effect计数=2。18条固定输入经历5个反压步骤，source侧最多积压9条，最终接受与消费均18、丢弃0。

扫描：正文149行；anti-ai-tone（tech profile）0错误0提醒，随后anti-persona-fabrication人工扫描通过。
构建与页面：Node 22.23.2全站`npm run build`退出0，生成5624个文件；正式HTML包含标题、正文结尾、第31篇链接、5个Mermaid源块和三个附件链接；生成附件与source逐字一致。云端无浏览器工具，未验证SVG尺寸、控制台和附件点击。
边界：有限状态模型，不是Flink运行；不验证真实barrier、connector、网络或性能。