beam.io.ReadFromBigQuery中的结果不一致

问题描述

我注意到 beam.io.ReadFromBigQuery 在运行多个管道时给出随机结果。我正在使用选项值提供程序传递查询

查询beam.io.ReadFromBigQuery(query=contact_options.tracking_query,use_standard_sql=True)

enter image description here

以上结果正确,管道成功(单个管道运行),以下数据错误,管道失败(多个管道运行)。

enter image description here

NB:同时运行多个作业时面临这些问题。有时更多的数据,有时更少的数据。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)