Apache Beam是否会发出关于丢弃了多少(延迟)消息的指标?
无论是在DirectRunner还是DataflowRunner。谢谢!
DirectRunner
DataflowRunner
在Cloud Dataflow上运行管道时,看起来有一个droppedDueToClosedWindow指标。
droppedDueToClosedWindow