Перекрестная публикация с https://groups.google.com/forum/#!topic/kythe/86kNuSCeorI,, так как я был направлен сюда Beam faq для вопросов Beam.
Короче говоря, я успешно выполняю работу, написанную с использованием golang sdk, используя direct runner, но при попытке использовать dataflow runner я получаю следующую ошибку в облачной консоли Google:
2019-02-17 (12:03:53) Шаг с именем e19 уже существует,Дубликаты не допускаются.
Я прикрепляю план, который был напечатан к stderr в https://pastebin.com/vpu3U52j. Подсказка для e19: https://pastebin.com/L24L1guT.
Я не очень знакомс лучом еще.Интересно, какая часть отвечает за генерацию имен шагов?Каковы вероятные причины столкновения?
Спасибо!