Java Beam SDK迁移Dataflow Runner v2遇Worker崩溃及性能劣化求助

我们团队此前使用Java Beam SDK搭配Dataflow Runner v1运行数据管道，一直稳定正常。近期尝试将管道迁移至Runner v2后，遇到两个核心问题：

• Worker崩溃：观测到Worker的CPU使用率骤降至0%，随后VM直接终止运行
• 资源占用飙升：相同流量下，Runner v2的CPU、内存资源消耗远高于Runner v1

同一管道在两个Runner版本下的资源使用对比图：

Runner v1 资源使用情况 #

Runner v2 资源使用情况 #

注：两个管道为并行运行，处理完全相同的流量。

已尝试的排查动作 #

• 检查Worker及Dataflow控制平面的日志，未发现明确的错误或警告信息
• 监控了Dataflow提供的各类指标（包括Worker资源、管道吞吐量、元素延迟等），未找到能解释性能差异的有效线索

需解答的问题 #

1. 这类Worker崩溃+资源占用异常的情况，是否属于Dataflow Runner v2的已知问题？
2. Java Beam SDK中是否存在某些特定功能，在Runner v2下存在兼容性或适配问题？
3. 从Runner v1迁移至v2的过程中，有哪些容易被忽略的优化步骤或配置调整建议？
4. 针对当前的故障现象，有哪些具体的排查技巧或指导方向？

内容的提问来源于stack exchange，提问作者lmva94