问题描述
我注意到 beam.io.ReadFromBigQuery 在运行多个管道时给出随机结果。我正在使用选项值提供程序传递查询。
查询:beam.io.ReadFromBigQuery(query=contact_options.tracking_query,use_standard_sql=True)
以上结果正确,管道成功(单个管道运行),以下数据错误,管道失败(多个管道运行)。
NB:同时运行多个作业时面临这些问题。有时更多的数据,有时更少的数据。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)