Відгуки: Serverless Data Processing with Dataflow - CI/CD with Dataflow

4567 відгуків

Felipe V. · Відгук надано майже 3 роки тому

Abhijeet G. · Відгук надано майже 3 роки тому

Anan A. · Відгук надано майже 3 роки тому

Exist a problem with composer enviroment create and I can't fix it

Adilene N. · Відгук надано майже 3 роки тому

Revanth M. · Відгук надано майже 3 роки тому

Sheik S. · Відгук надано майже 3 роки тому

Composer command error (image-version not specified) that I did not solved

Sophie H. · Відгук надано майже 3 роки тому

Adilene N. · Відгук надано майже 3 роки тому

Sergio C. · Відгук надано майже 3 роки тому

Multiple Issues with Airflow versioning, this lab is outdated

Alfonso G. · Відгук надано майже 3 роки тому

Multiple Issues with Airflow versioning, this lab is outdated

Alfonso G. · Відгук надано майже 3 роки тому

Ilkin I. · Відгук надано майже 3 роки тому

Pedro A. · Відгук надано майже 3 роки тому

Revanth M. · Відгук надано майже 3 роки тому

Revanth M. · Відгук надано майже 3 роки тому

정아 원. · Відгук надано майже 3 роки тому

Multiple Issues with Airflow versioning, this lab is outdated

Alfonso G. · Відгук надано майже 3 роки тому

[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

João Borges F. · Відгук надано майже 3 роки тому

[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

João Borges F. · Відгук надано майже 3 роки тому

Noura A. · Відгук надано майже 3 роки тому

[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

João Borges F. · Відгук надано майже 3 роки тому

Noura A. · Відгук надано майже 3 роки тому

Angel T. · Відгук надано майже 3 роки тому

Angel T. · Відгук надано майже 3 роки тому

Ми не гарантуємо, що опубліковані відгуки написали клієнти, які придбали продукти чи скористалися ними. Відгуки не перевіряються Google.