为了账号安全,请及时绑定邮箱和手机立即绑定

Apache Beam Wait.on JdbcIO.write 存在无界 PCollection

Apache Beam Wait.on JdbcIO.write 存在无界 PCollection

慕侠2389804 2023-11-10 16:15:51
我正在尝试将以下场景与无界 pCollection 数据源(PubSub)一起使用。 https://issues.apache.org/jira/browse/BEAM-6732我能够写入 DB1。DB2 正在等待 DB1 (PCollection .withResults)。但不幸的是 DB2 没有得到更新。当我将源更改为有界虚拟 PCollection 时,它可以工作。任何意见都会受到赞赏。
查看完整描述

1 回答

?
白猪掌柜的

TA贡献1893条经验 获得超10个赞

正如我在 Jira 中提到的,您的无限管道中是否使用了任何 Windows?仅当相应窗口完全写入第一个数据库后,才会开始写入另一个数据库。否则,它将永远等待。



查看完整回答
反对 回复 2023-11-10
  • 1 回答
  • 0 关注
  • 91 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信