耗尽从PubSub读取并写入Google云端存储的Dataflow作业时的数据丢失

When putting a fixed number of strings (800,000 1KB used to test) into a PubSub topic and running the following Apache Beam (2.1.0) job in Dataflow, exactly once semantics are preserved as expected.When putting a fixed number of strings (800,000