- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我有一个谷歌云数据流作业(使用 apache beam python sdk)每 6 分钟安排一次,它在内部从 Big Query Table 读取,进行一些转换并写入另一个 Big Query 表。此作业已开始间歇性失败(大约 10 次中有 4 次)并出现以下错误跟踪。
2021-02-17 14:51:18.146 ISTError message from worker: Traceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/dataflow_worker/batchworker.py", line 649, in do_work
work_executor.execute()
File "/usr/local/lib/python3.8/site-packages/dataflow_worker/executor.py", line 225, in execute
self.response = self._perform_source_split_considering_api_limits(
File "/usr/local/lib/python3.8/site-packages/dataflow_worker/executor.py", line 233, in _perform_source_split_considering_api_limits
split_response = self._perform_source_split(source_operation_split_task,
File "/usr/local/lib/python3.8/site-packages/dataflow_worker/executor.py", line 271, in _perform_source_split
for split in source.split(desired_bundle_size):
File "/usr/local/lib/python3.8/site-packages/apache_beam/io/gcp/bigquery.py", line 807, in split
self.table_reference = self._execute_query(bq)
File "/usr/local/lib/python3.8/site-packages/apache_beam/options/value_provider.py", line 135, in _f
return fnc(self, *args, **kwargs)
File "/usr/local/lib/python3.8/site-packages/apache_beam/io/gcp/bigquery.py", line 851, in _execute_query
job = bq._start_query_job(
File "/usr/local/lib/python3.8/site-packages/apache_beam/utils/retry.py", line 236, in wrapper
return fun(*args, **kwargs)
File "/usr/local/lib/python3.8/site-packages/apache_beam/io/gcp/bigquery_tools.py", line 459, in _start_query_job
response = self.client.jobs.Insert(request)
File "/usr/local/lib/python3.8/site-packages/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py", line 344, in Insert
return self._RunMethod(
File "/usr/local/lib/python3.8/site-packages/apitools/base/py/base_api.py", line 731, in _RunMethod
return self.ProcessHttpResponse(method_config, http_response, request)
File "/usr/local/lib/python3.8/site-packages/apitools/base/py/base_api.py", line 737, in ProcessHttpResponse
self.__ProcessHttpResponse(method_config, http_response, request))
File "/usr/local/lib/python3.8/site-packages/apitools/base/py/base_api.py", line 603, in __ProcessHttpResponse
raise exceptions.HttpError.FromResponse( apitools.base.py.exceptions.HttpConflictError: HttpError accessing <https://bigquery.googleapis.com/bigquery/v2/projects/bbb-erizo/jobs?alt=json>:
response: <{
'vary': 'Origin, X-Origin, Referer',
'content-type': 'application/json; charset=UTF-8',
'date': 'Wed, 17 Feb 2021 09:21:17 GMT',
'server': 'ESF',
'cache-control': 'private',
'x-xss-protection': '0',
'x-frame-options': 'SAMEORIGIN',
'x-content-type-options': 'nosniff',
'transfer-encoding': 'chunked',
'status': '409',
'content-length': '402',
'-content-encoding': 'gzip'
}>,
content <{
"error": {
"code": 409,
"message": "Already Exists: Job bbb-erizo:asia-northeast1.beam_bq_job_QUERY_AUTOMATIC_JOB_NAME_a2207822-8_754",
"errors": [ {
"message": "Already Exists: Job bbb-erizo:asia-northeast1.beam_bq_job_QUERY_AUTOMATIC_JOB_NAME_a2207822-8_754",
"domain": "global", "reason": "duplicate"
} ],
"status": "ALREADY_EXISTS"
}
} >
从错误跟踪来看,数据流作业为 BQ 生成的作业 ID 似乎是如何重复的或其他原因,但由于我没有明确分配 BQ 作业 ID,因为它是由 Dataflow 本身完成的,所以我没有任何控制权那部分。
求推荐!!
最佳答案
这是一个错误。它应该用 https://github.com/apache/beam/pull/13749 修复这将成为 Beam 2.28.0 的一部分。
关于python-3.x - 启动 Bigquery 作业的数据流作业间歇性失败,出现错误 "errors": [ { "message": "Already Exists: Job,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/66240753/
最近我将 sonarqube 从 4.0 升级到 4.3.3。升级后当我尝试运行 maven 构建时出现错误: Failed to execute goal org.codehaus.mojo:son
在下面的类中: class TestClass { public: int staic testMember; }; int TestClass::testMember; 我遇到了以下编译器
我以前也遇到过这个错误,但这次有点不同。 当我向 Forge 推送更新时,Laravel Forge 说它部署失败,但它部署得很好。由于此错误,它只是没有对数据库结构进行任何更改: [Doctrine
此错误显然源于 xlsxwriter。我不确定它来自我的代码的哪一行,因为每次我尝试调试时,我的编辑器 Visual Studio 2019 都会崩溃。但是,在使用 VPN 和远程桌面连接时,我在笔记
我自己尝试将magento版本1.9.1升级到1.9.2.2 引用链接:http://www.hostknox.com/tutorials/magento/upgrade-with-connect-m
这是我的迁移表 increments('id'); $table->integer('role_id')->unsigned(); $table
注册表要求提供用户名和电子邮件地址。数据通过验证后,将添加到 accounts 表中。它存储用户名、密码和电子邮件地址等数据。如果用户名已被占用,用户将收到通知,并且不会将任何数据添加到表中。它被视为
规范: Laravel 版本:5.4PHP版本:7.0.9 Composer 版本 1.9.0XAMP 描述: 在 Connection.php 第 647 行: SQLSTATE[42S01]: 基
当我迁移一个表时,我看到了这个错误, SQLSTATE[42S01]: Base table or view already exists: 1050 Table 'payments' already
问题现场: 原因: HttpServletRequest 的 getInputStream() 和 getReader() 都只能读取一次。 因为 我们使用@RequestBody 注解,读取body
mysql新手。尝试创建我在本教程中看到的存储过程:http://www.microshell.com/database/mysql/emulating-nextval-function-to-get
我只是尝试使用 TortoiseSVN 添加和提交大约 25,000 个文件到 VisualSVN。 提交对话框被锁定(我猜是预料之中的),但是在线程被阻塞一段时间后,我杀死了 Tortoise,希望
我有一个 scala 项目,当从命令行使用 SBT 时,它可以正常编译、运行和测试。但是,在intellij中构建项目时,项目中的每个类的事件日志中似乎都有此错误,导致构建失败: SendComman
当尝试将更改提交到存储库(我是唯一的用户)时,我收到错误 Path '/trunk/TemplatesLibrary/constraints/templates/TP145210GB01_Person
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; usin
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; usin
我正在使用 Metro 2.0.1 作为安全连接到 WCF 服务的客户端应用程序。在我的单元测试中一切正常,但是当我在 Java 应用程序中调用该方法时,出现以下异常: Exception in th
我正在使用 azure-documentdb java SDK为了创建和使用“用户定义函数 (UDF)” 因此来自 official documentation我终于找到了如何创建 UDF 的方法(使
我有一个 JButton,按下时会启动倒计时器。当我按下按钮时,它开始,当我再次按下它时(按钮会说“停止”),它停止。但是,当我再次按下它再次开始计时时,我收到一条错误消息: Exception in
通过设置 innerHTML 插入的脚本,以及调用 element.cloneNode(true) 等其他一些情况将生成具有内部“已启动”标志集的脚本为真。 The first is a flag i
我是一名优秀的程序员,十分优秀!