В облаке Google работает потоковый поток данных (Apache beam 2.5). Поток данных показывал некоторое системное отставание, поэтому я пытаюсь обновить этот поток данных с помощью флага --update. Теперь старый поток данных находится в состоянии обновления, а новый поток данных, инициированный после процесса обновления, находится в состоянии ожидания.
Теперь на этом этапе все застряло. Я не могу остановить / отменить работу сейчас. Старая работа все еще находится в состоянии обновления, и никакая операция по изменению статуса не разрешена. Я пытался изменить состояние задания с помощью отмены заданий потока данных gcloud и API REST, но это показывает, что задание не может быть обновлено, поскольку оно находится в состоянии RELOAD. Новое инициирующее задание находится в незапущенном / ожидающем состоянии. Невозможно изменить состояние этого также. Это показывает, что задание не в состоянии выполнить эту операцию.
Пожалуйста, дайте мне знать, как остановить / отменить / удалить этот поток данных потока.