如何在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。