This is regarding Apache beam not regarding Airflow. I am using Apache Beam 2.4 version.
On 7 May 2018 at 21:22, Driesprong, Fokko <[email protected]> wrote: > Hi Prabeesh, > > Thanks for reaching out. What version are you running and do you have the > full stacktrace? It looks like there is missing a part (I don't see any > references to Airflow). > > Cheers, Fokko > > 2018-05-07 6:42 GMT+02:00 Prabeesh K. <[email protected]>: > >> Hi, >> >> Please help me to fix this error. The job seems running in the dataflow >> console. But getting following assertion error. >> >> >> /local/lib/python2.7/site-packages/apache_beam/io/gcp/gcsio.py:166: >> DeprecationWarning: object() takes no parameters >> super(GcsIO, cls).__new__(cls, storage_client)) >> Traceback (most recent call last): >> File "/usr/lib/python2.7/runpy.py", line 174, in _run_module_as_main >> "__main__", fname, loader, pkg_name) >> File "/usr/lib/python2.7/runpy.py", line 72, in _run_code >> exec code in run_globals >> File "/home/gw/src/legacy/dataflow/cma/report/build.py", line 96, in >> <module> >> run() >> File "/home/gw/src/legacy/dataflow/cma/report/build.py", line 91, in run >> return p.run().wait_until_finish() >> File >> "/home/gw/venvs/dfvenv-0.2.0/local/lib/python2.7/site-packages/apache_beam/runners/dataflow/dataflow_runner.py", >> line 989, in wait_until_finish >> 'Job did not reach to a terminal state after waiting indefinitely.') >> AssertionError: Job did not reach to a terminal state after waiting >> indefinitely. >> >> >> >> Regards, >> Prabeesh K. >> > >
