我无法使批处理 fn 在数据流上工作。我在 Go 中使用了示例中的那个：https://beam.apache.org/documentation/programming-guide/#state-timers-examples
dofn 接收元素并触发 OnTimer 一次，然后一切都卡住了（我可以通过日志看到它）。
我处于流媒体模式。所以我的第一个问题是 Dataflow 支持 Go 中的计时器吗？如果是的话我做错了什么？我从字面上复制了这个例子。
好的，对于在 Dataflow 上遇到相同问题的每个人，您必须添加此行作为 OnTimer() 回调：
fn.OutputState.ClearTag(tp, timer.Tag) // Clean up the fired timer tag. (Temporary workaround for a runner bug.)
（此行出现在 github 上的示例中，但不在文档中）