Dataflow によるサーバーレス データ処理 – Dataflow を使用した CI / CD のレビュー

Cobos García Sergio · 2年以上前にレビュー済み

Multiple Issues with Airflow versioning, this lab is outdated

Gonzalez Alfonso · 2年以上前にレビュー済み

Multiple Issues with Airflow versioning, this lab is outdated

Gonzalez Alfonso · 2年以上前にレビュー済み

Iskandarov Ilkin · 2年以上前にレビュー済み

Azcona Pedro · 2年以上前にレビュー済み

Merugu Revanth · 2年以上前にレビュー済み

Merugu Revanth · 2年以上前にレビュー済み

원 정아 · 2年以上前にレビュー済み

Multiple Issues with Airflow versioning, this lab is outdated

Gonzalez Alfonso · 2年以上前にレビュー済み

[2023-03-05 15:07:22,501] {taskinstance.py:1152} ERROR - Google Cloud Dataflow job wordcount-run-f228c786 has failed. Traceback (most recent call last): File "/usr/local/lib/airflow/airflow/models/taskinstance.py", line 985, in _run_raw_task result = task_copy.execute(context=context) File "/usr/local/lib/airflow/airflow/contrib/operators/dataflow_operator.py", line 184, in execute hook.start_java_dataflow(self.job_name, dataflow_options, File "/usr/local/lib/airflow/airflow/contrib/hooks/gcp_dataflow_hook.py", line 228, in start_java_dataflow self._start_dataflow(variables, name, command_prefix, label_formatter) File "/usr/local/lib/airflow/airflow/contrib/hooks/gcp_api_base_hook.py", line 363, in wrapper return func(self, *args, **kwargs) File "/usr/local/lib/airflow/airflow/contrib/hooks/gcp_dataflow_hook.py", line 205, in _start_dataflow _DataflowJob(self.get_conn(), variables['project'], name, File "/usr/local/lib/airflow/airflow/contrib/hooks/gcp_dataflow_hook.py", line 96, in wait_for_done raise Exception("Google Cloud Dataflow job {} has failed.".format( Exception: Google Cloud Dataflow job wordcount-run-f228c786 has failed. [2023-03-05 15:07:22,505] {taskinstance.py:1189} INFO - Marking task as FAILED. dag_id=test_word_count, task_id=wordcount-run, execution_date=20230305T150602, start_date=20230305T150612, end_date=20230305T150722 [2023-03-05 15:07:27,541] {local_task_job.py:102} INFO - Task exited with return code 1

Ferreira Júnior João Borges · 2年以上前にレビュー済み

[2023-03-05 15:07:22,501] {taskinstance.py:1152} ERROR - Google Cloud Dataflow job wordcount-run-f228c786 has failed. Traceback (most recent call last): File "/usr/local/lib/airflow/airflow/models/taskinstance.py", line 985, in _run_raw_task result = task_copy.execute(context=context) File "/usr/local/lib/airflow/airflow/contrib/operators/dataflow_operator.py", line 184, in execute hook.start_java_dataflow(self.job_name, dataflow_options, File "/usr/local/lib/airflow/airflow/contrib/hooks/gcp_dataflow_hook.py", line 228, in start_java_dataflow self._start_dataflow(variables, name, command_prefix, label_formatter) File "/usr/local/lib/airflow/airflow/contrib/hooks/gcp_api_base_hook.py", line 363, in wrapper return func(self, *args, **kwargs) File "/usr/local/lib/airflow/airflow/contrib/hooks/gcp_dataflow_hook.py", line 205, in _start_dataflow _DataflowJob(self.get_conn(), variables['project'], name, File "/usr/local/lib/airflow/airflow/contrib/hooks/gcp_dataflow_hook.py", line 96, in wait_for_done raise Exception("Google Cloud Dataflow job {} has failed.".format( Exception: Google Cloud Dataflow job wordcount-run-f228c786 has failed. [2023-03-05 15:07:22,505] {taskinstance.py:1189} INFO - Marking task as FAILED. dag_id=test_word_count, task_id=wordcount-run, execution_date=20230305T150602, start_date=20230305T150612, end_date=20230305T150722 [2023-03-05 15:07:27,541] {local_task_job.py:102} INFO - Task exited with return code 1

Ferreira Júnior João Borges · 2年以上前にレビュー済み

Aldossery Noura · 2年以上前にレビュー済み

[2023-03-05 15:07:22,501] {taskinstance.py:1152} ERROR - Google Cloud Dataflow job wordcount-run-f228c786 has failed. Traceback (most recent call last): File "/usr/local/lib/airflow/airflow/models/taskinstance.py", line 985, in _run_raw_task result = task_copy.execute(context=context) File "/usr/local/lib/airflow/airflow/contrib/operators/dataflow_operator.py", line 184, in execute hook.start_java_dataflow(self.job_name, dataflow_options, File "/usr/local/lib/airflow/airflow/contrib/hooks/gcp_dataflow_hook.py", line 228, in start_java_dataflow self._start_dataflow(variables, name, command_prefix, label_formatter) File "/usr/local/lib/airflow/airflow/contrib/hooks/gcp_api_base_hook.py", line 363, in wrapper return func(self, *args, **kwargs) File "/usr/local/lib/airflow/airflow/contrib/hooks/gcp_dataflow_hook.py", line 205, in _start_dataflow _DataflowJob(self.get_conn(), variables['project'], name, File "/usr/local/lib/airflow/airflow/contrib/hooks/gcp_dataflow_hook.py", line 96, in wait_for_done raise Exception("Google Cloud Dataflow job {} has failed.".format( Exception: Google Cloud Dataflow job wordcount-run-f228c786 has failed. [2023-03-05 15:07:22,505] {taskinstance.py:1189} INFO - Marking task as FAILED. dag_id=test_word_count, task_id=wordcount-run, execution_date=20230305T150602, start_date=20230305T150612, end_date=20230305T150722 [2023-03-05 15:07:27,541] {local_task_job.py:102} INFO - Task exited with return code 1

Ferreira Júnior João Borges · 2年以上前にレビュー済み

Aldossery Noura · 2年以上前にレビュー済み

Torres Angel · 2年以上前にレビュー済み

Torres Angel · 2年以上前にレビュー済み

Ahmed Ola · 2年以上前にレビュー済み

Task 2: Not defining --image-version resolves to Cloud Composer current default version, which changed from 1 to 2 in a recent release and is subject to further changes in the future. Consider using --image-version=composer-A-airflow-X[.Y[.Z]]. More info at https://cloud.google.com/composer/docs/concepts/versioning/composer-versioning-overview#version-aliases ERROR: (gcloud.composer.environments.create) Cannot specify --python-version with Composer 2.X or greater. GCP get your sh## together please waste my time. and I paid premium sub

Bin Rahim Ridhwan · 2年以上前にレビュー済み

Alahmadi Mona · 2年以上前にレビュー済み

Tifa Feng · 2年以上前にレビュー済み

golla chaitanya · 2年以上前にレビュー済み

Prava (LatentView) Lakshmi Sahithi · 2年以上前にレビュー済み

Task 2: Composer creation failed over Cloud Shell. The command is wrong. Workaround over UI and grant missing permissions on service-account. Fails again in Task 5. DAG gets invaild code... .

Jennert Robert · 2年以上前にレビュー済み

Pippari Anusha · 2年以上前にレビュー済み