title: How to continue processing when VM instances are stopped?
body: <p>I'm using streaming word count on dataflow.The flow is "pubsub -> wordcount on dataflow (fixed window) -> pubsub".</p>
  
  <p>When I deploy the pipeline, 3 instances are up.
  [<a href="https://s3-ap-northeast-1.amazonaws.com/matsuda-question/instances.png]" rel="nofollow">https://s3-ap-northeast-1.amazonaws.com/matsuda-question/instances.png]</a></p>
  
  <p>When I publish the text to pubsub, the counted result are publishued to pubsub.
  [<a href="https://s3-ap-northeast-1.amazonaws.com/matsuda-question/input.png]" rel="nofollow">https://s3-ap-northeast-1.amazonaws.com/matsuda-question/input.png]</a>
  [<a href="https://s3-ap-northeast-1.amazonaws.com/matsuda-question/output1.png]" rel="nofollow">https://s3-ap-northeast-1.amazonaws.com/matsuda-question/output1.png]</a></p>
  
  <p>And I manually stop 1 instance of 3 instances. It's like node failure.
  [<a href="https://s3-ap-northeast-1.amazonaws.com/matsuda-question/stopped_instances.png]" rel="nofollow">https://s3-ap-northeast-1.amazonaws.com/matsuda-question/stopped_instances.png]</a></p>
  
  <p>The count is not complete. 
  [<a href="https://s3-ap-northeast-1.amazonaws.com/matsuda-question/output2.png]" rel="nofollow">https://s3-ap-northeast-1.amazonaws.com/matsuda-question/output2.png]</a></p>
  
  <p>I guess the node which handles the words "one, two, five" is stopped.
  Doesn't dataflow have failover function when some nodes are failure?</p>