На основании документа https://cloud.google.com/dataflow/docs/resources/faq
"Однако, как только ваша работа завершится или произойдет сбой, служба облачных данных автоматически отключится и очистит экземпляры виртуальной машины."
Это легко понять для Batch.Но для потоковой передачи сообщение pub / sub будет продолжать поступать, как поток данных обрабатывает это?неэффективно продолжать выключать и очищать экземпляры виртуальных машин.Но также экономически невыгодно постоянно поддерживать экземпляры виртуальных машин.
Спасибо