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