一个使用窗口化和转换处理 Pub/Sub 流数据的 Cloud Dataflow 作业在流式插入时失败。最可能的原因是什么？

在处理 Pub/Sub 流数据时，如果 Dataflow 作业需要进行窗口化和转换，但没有应用非全局（分片）窗口函数，那么在管道创建时就会失败。这是因为流处理通常需要将无限数据流分成有限的逻辑块（窗口）进行处理。如果没有定义这些窗口，Dataflow 无法知道如何聚合或转换数据，导致管道构建失败。 其他选项不正确： 未分配事件时间戳通常会导致数据处理不准确或乱序，而不是作业在创建时就失败。 未配置触发器来处理延迟数据会导致延迟数据被丢弃或处理不当，但不会阻止管道创建。 未应用全局窗口函数通常不会导致作业在创建时失败，因为全局窗口是默认行为，但对于需要聚合的流数据，通常需要更细粒度的窗口。