英文: Airflow DAG does not run on schedule, "next run" is 4 hours ago 问题 I have an Airflow D...
BigQuery running in Airflow is running query in incorrect region even though different region is explicitly specified
英文: BigQuery running in Airflow is running query in incorrect region even though different region is...
DAG运行标记为成功,而任务失败。
英文: DAG run marked as success while task failed 问题 def my_main(**kwargs): try: .... except: print(...
Airflow – 为Big Query结果集的每一行进行HTTP请求
英文: Airflow - Make http request for each row of Big Query Result Set 问题 我想使用Airflow DAG执行GCP Big Que...
Presto是否支持插入覆盖到Hive表格?
英文: Does presto support insert overwrite into hive table? 问题 我正在尝试将数据插入到一个分区表中。我正在使用PrestoSqlOperato...
Kubernetes中的执行器Pod在提交Spark作业到K8s时不断创建然后移除。
英文: the executor pod in kubernetes keeps create then remove when submit spark job to k8s 问题 我通过Airfl...
retry_exponential_backoff在Airflow任务中是如何工作的?
英文: How does retry_exponential_backoff work in Airflow tasks? 问题 retries 参数设置为3,retry_delay 参数设置为300...
NameError: name ‘pd’ is defined 当加载一个pickle文件时 – 但pandas已经定义
英文: NameError: name 'pd' is not defined when loading a pickled file - but pandas IS defined ...
管理Google表格中的BigQuery表格
英文: Manage Big Query table from Google Sheet 问题 我使用Airflow将大量Google表格中的数据导入BigQuery,这些表格使用写入截断方法。但我遇...
Airflow Kubernetes Pod Operator中的XCom返回值在pythonOperator中访问时为”None”。
英文: Airflow Kubernetes Pod Operator XCom return value is "None" when accessed in pythonOpe...
9