如何在VM實例停止時繼續處理？

Question

我在數據流上使用流式字數。流是「pubsub - > wordcount數據流（固定窗口） - > pubsub」。

當我部署管道時，有3個實例啓動。 [https://s3-ap-northeast-1.amazonaws.com/matsuda-question/instances.png]

當我將文本發佈到pubsub時，計數結果被髮布到pubsub。 [https://s3-ap-northeast-1.amazonaws.com/matsuda-question/input.png] [https://s3-ap-northeast-1.amazonaws.com/matsuda-question/output1.png]

我手動停止3個實例1個實例。這就像節點故障。 [https://s3-ap-northeast-1.amazonaws.com/matsuda-question/stopped_instances.png]

計數不完整。 [https://s3-ap-northeast-1.amazonaws.com/matsuda-question/output2.png]

我想停止處理單詞「一，二，五」的節點。 某些節點出現故障時，數據流是否具有故障切換功能？

Answer 1

流數據流當前不處理正在運行的作業中間的停止實例。但是，這在計算引擎中不是可能的故障模式。保證失敗的VM將會重新啓動。如果您想試驗節點失敗時管道的行爲方式，可以從開發人員控制檯重置VM。