使用 google 云数据流 PubSubIO，消息的读取何时得到确认？
Using google cloud dataflow PubSubIO, when does the read of the message get acknowledged?
是否可以延迟确认直到子图（PubSubIO.Read 下的所有内容）被成功处理？
例如，我们 streaming 从 google pubsub 订阅中读取，然后将文件写入 GCS，在另一个分支中，我们使用 BigQueryIO.Write...
我们确实看到，如果发生异常，它将无限期地重试，因为我们处于流模式。但是，如果我们取消作业并通过更改代码重新部署，则不会重新处理消息。
一旦消息持久保存在数据流管道中的某处，就会进行确认。如果您想在不丢失运行中数据的情况下更改管道，请使用更新功能而不是取消：https://cloud.google.com/dataflow/pipelines/updating-a-pipeline
是否可以延迟确认直到子图（PubSubIO.Read 下的所有内容）被成功处理？
例如，我们 streaming 从 google pubsub 订阅中读取，然后将文件写入 GCS，在另一个分支中，我们使用 BigQueryIO.Write...
我们确实看到，如果发生异常，它将无限期地重试，因为我们处于流模式。但是，如果我们取消作业并通过更改代码重新部署，则不会重新处理消息。
一旦消息持久保存在数据流管道中的某处，就会进行确认。如果您想在不丢失运行中数据的情况下更改管道，请使用更新功能而不是取消：https://cloud.google.com/dataflow/pipelines/updating-a-pipeline