2019-02-17 18:00 阅读 19


Cross-posting from https://groups.google.com/forum/#!topic/kythe/86kNuSCeorI, since I was directed here by Beam faq for Beam questions.

In short, I run a job written using the golang sdk successfully using the direct runner, but trying to use the dataflow runner I get the following error in the google cloud console:

2019-02-17 (12:03:53) Step with name e19 already exists. Duplicates are not allowed.

I attach the plan that was printed to the stderr at https://pastebin.com/vpu3U52j. Grepping for e19: https://pastebin.com/L24L1guT.

I'm not very familiar with beam yet. I wonder which part is responsible for generating the step names? What are likely causes of a collision?

Thank you!

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享

1条回答 默认 最新

  • 已采纳
    dongnachuang6635 dongnachuang6635 2019-02-19 20:27

    It was a bug actually, sent PR to beam.

    点赞 评论 复制链接分享