我正在嘗試將以下場景與無界 pCollection 數據源（PubSub）一起使用。 https://issues.apache.org/jira/browse/BEAM-6732我能夠寫入 DB1。DB2 正在等待 DB1 (PCollection .withResults)。但不幸的是 DB2 沒有得到更新。當我將源更改為有界虛擬 PCollection 時，它可以工作。任何意見都會受到贊賞。
1 回答
白豬掌柜的
TA貢獻1893條經驗 獲得超10個贊
正如我在 Jira 中提到的，您的無限管道中是否使用了任何 Windows？僅當相應窗口完全寫入第一個數據庫后，才會開始寫入另一個數據庫。否則，它將永遠等待。
添加回答
舉報
0/150
提交
取消