SHIVAPRASAD96 opened a new issue #16910:
URL: https://github.com/apache/airflow/issues/16910
Traceback (most recent call last):
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/base.py",
line 1277, in _execute_context
cursor, statement, parameters, context
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/default.py", line
608, in do_execute
cursor.execute(statement, parameters)
psycopg2.errors.UndefinedTable: relation "job" does not exist
LINE 1: INSERT INTO job (dag_id, state, job_type, start_date, end_da...
^
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/usr/local/bin/airflow", line 11, in <module>
sys.exit(main())
File "/usr/local/lib/python3.6/dist-packages/airflow/__main__.py", line
40, in main
args.func(args)
File "/usr/local/lib/python3.6/dist-packages/airflow/cli/cli_parser.py",
line 48, in command
return func(*args, **kwargs)
File "/usr/local/lib/python3.6/dist-packages/airflow/utils/cli.py", line
91, in wrapper
return f(*args, **kwargs)
File
"/usr/local/lib/python3.6/dist-packages/airflow/cli/commands/scheduler_command.py",
line 64, in scheduler
job.run()
File "/usr/local/lib/python3.6/dist-packages/airflow/jobs/base_job.py",
line 233, in run
session.commit()
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/session.py",
line 1046, in commit
self.transaction.commit()
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/session.py",
line 504, in commit
self._prepare_impl()
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/session.py",
line 483, in _prepare_impl
self.session.flush()
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/session.py",
line 2540, in flush
self._flush(objects)
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/session.py",
line 2682, in _flush
transaction.rollback(_capture_exception=True)
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/util/langhelpers.py", line
70, in __exit__
with_traceback=exc_tb,
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/util/compat.py",
line 182, in raise_
raise exception
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/session.py",
line 2642, in _flush
flush_context.execute()
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/unitofwork.py", line
422, in execute
rec.execute(self)
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/unitofwork.py", line
589, in execute
uow,
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/persistence.py", line
245, in save_obj
insert,
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/persistence.py", line
1136, in _emit_insert_statements
statement, params
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/base.py",
line 1011, in execute
return meth(self, multiparams, params)
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/sql/elements.py",
line 298, in _execute_on_connection
return connection._execute_clauseelement(self, multiparams, params)
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/base.py",
line 1130, in _execute_clauseelement
distilled_params,
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/base.py",
line 1317, in _execute_context
e, statement, parameters, cursor, context
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/base.py",
line 1511, in _handle_dbapi_exception
sqlalchemy_exception, with_traceback=exc_info[2], from_=e
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/util/compat.py",
line 182, in raise_
raise exception
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/base.py",
line 1277, in _execute_context
cursor, statement, parameters, context
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/default.py", line
608, in do_execute
cursor.execute(statement, parameters)
sqlalchemy.exc.ProgrammingError: (psycopg2.errors.UndefinedTable) relation
"job" does not exist
LINE 1: INSERT INTO job (dag_id, state, job_type, start_date, end_da...
^
[SQL: INSERT INTO job (dag_id, state, job_type, start_date, end_date,
latest_heartbeat, executor_class, hostname, unixname) VALUES (%(dag_id)s,
%(state)s, %(job_type)s, %(start_date)s, %(end_date)s, %(latest_heartbeat)s,
%(executor_class)s, %(hostname)s, %(unixname)s) RETURNING job.id]
[parameters: {'dag_id': None, 'state': 'running', 'job_type':
'SchedulerJob', 'start_date': datetime.datetime(2021, 7, 9, 11, 20, 54, 327676,
tzinfo=Timezone('UTC')), 'end_date': None, 'latest_heartbeat':
datetime.datetime(2021, 7, 9, 11, 20, 54, 327691, tzinfo=Timezone('UTC')),
'executor_class': 'SequentialExecutor', 'hostname': 'BEK-43004625.bcg.com',
'unixname': 'root'}]
(Background on this error at: http://sqlalche.me/e/13/f405)
^Z
[1]+ Stopped airflow scheduler
root@BEK-43004625:~/airflow# airflow scheduler > error_airflow.txt
Traceback (most recent call last):
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/base.py",
line 1277, in _execute_context
cursor, statement, parameters, context
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/default.py", line
608, in do_execute
cursor.execute(statement, parameters)
psycopg2.errors.UndefinedTable: relation "job" does not exist
LINE 1: INSERT INTO job (dag_id, state, job_type, start_date, end_da...
^
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/usr/local/bin/airflow", line 11, in <module>
sys.exit(main())
File "/usr/local/lib/python3.6/dist-packages/airflow/__main__.py", line
40, in main
args.func(args)
File "/usr/local/lib/python3.6/dist-packages/airflow/cli/cli_parser.py",
line 48, in command
return func(*args, **kwargs)
File "/usr/local/lib/python3.6/dist-packages/airflow/utils/cli.py", line
91, in wrapper
return f(*args, **kwargs)
File
"/usr/local/lib/python3.6/dist-packages/airflow/cli/commands/scheduler_command.py",
line 64, in scheduler
job.run()
File "/usr/local/lib/python3.6/dist-packages/airflow/jobs/base_job.py",
line 233, in run
session.commit()
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/session.py",
line 1046, in commit
self.transaction.commit()
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/session.py",
line 504, in commit
self._prepare_impl()
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/session.py",
line 483, in _prepare_impl
self.session.flush()
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/session.py",
line 2540, in flush
self._flush(objects)
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/session.py",
line 2682, in _flush
transaction.rollback(_capture_exception=True)
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/util/langhelpers.py", line
70, in __exit__
with_traceback=exc_tb,
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/util/compat.py",
line 182, in raise_
raise exception
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/session.py",
line 2642, in _flush
flush_context.execute()
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/unitofwork.py", line
422, in execute
rec.execute(self)
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/unitofwork.py", line
589, in execute
uow,
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/persistence.py", line
245, in save_obj
insert,
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/orm/persistence.py", line
1136, in _emit_insert_statements
statement, params
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/base.py",
line 1011, in execute
return meth(self, multiparams, params)
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/sql/elements.py",
line 298, in _execute_on_connection
return connection._execute_clauseelement(self, multiparams, params)
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/base.py",
line 1130, in _execute_clauseelement
distilled_params,
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/base.py",
line 1317, in _execute_context
e, statement, parameters, cursor, context
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/base.py",
line 1511, in _handle_dbapi_exception
sqlalchemy_exception, with_traceback=exc_info[2], from_=e
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/util/compat.py",
line 182, in raise_
raise exception
File "/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/base.py",
line 1277, in _execute_context
cursor, statement, parameters, context
File
"/usr/local/lib/python3.6/dist-packages/sqlalchemy/engine/default.py", line
608, in do_execute
cursor.execute(statement, parameters)
sqlalchemy.exc.ProgrammingError: (psycopg2.errors.UndefinedTable) relation
"job" does not exist
LINE 1: INSERT INTO job (dag_id, state, job_type, start_date, end_da...
^
[SQL: INSERT INTO job (dag_id, state, job_type, start_date, end_date,
latest_heartbeat, executor_class, hostname, unixname) VALUES (%(dag_id)s,
%(state)s, %(job_type)s, %(start_date)s, %(end_date)s, %(latest_heartbeat)s,
%(executor_class)s, %(hostname)s, %(unixname)s) RETURNING job.id]
[parameters: {'dag_id': None, 'state': 'running', 'job_type':
'SchedulerJob', 'start_date': datetime.datetime(2021, 7, 9, 11, 28, 19, 720930,
tzinfo=Timezone('UTC')), 'end_date': None, 'latest_heartbeat':
datetime.datetime(2021, 7, 9, 11, 28, 19, 720943, tzinfo=Timezone('UTC')),
'executor_class': 'SequentialExecutor', 'hostname': 'BEK-43004625.bcg.com',
'unixname': 'root'}]
(Background on this error at: http://sqlalche.me/e/13/f405)
^Z
[2]+ Stopped airflow scheduler > error_airflow.txt
root@BEK-43004625:~/airflow# ls
airflow-webserver.pid airflow.cfg error_airflow.txt logs
webserver_config.py
root@BEK-43004625:~/airflow# cat error_airflow.txt
[2021-07-09 16:58:19,699] {cli_action_loggers.py:105} WARNING - Failed to
log action with (psycopg2.errors.UndefinedTable) relation "log" does not exist
LINE 1: INSERT INTO log (dttm, dag_id, task_id, event, execution_dat...
^
[SQL: INSERT INTO log (dttm, dag_id, task_id, event, execution_date, owner,
extra) VALUES (%(dttm)s, %(dag_id)s, %(task_id)s, %(event)s,
%(execution_date)s, %(owner)s, %(extra)s) RETURNING log.id]
[parameters: {'dttm': datetime.datetime(2021, 7, 9, 11, 28, 19, 452531,
tzinfo=Timezone('UTC')), 'dag_id': None, 'task_id': None, 'event':
'cli_scheduler', 'execution_date': None, 'owner': 'root', 'extra':
'{"host_name": "BEK-43004625", "full_command": "[\'/usr/local/bin/airflow\',
\'scheduler\']"}'}]
(Background on this error at: http://sqlalche.me/e/13/f405)
____________ _____________
____ |__( )_________ __/__ /________ __
____ /| |_ /__ ___/_ /_ __ /_ __ \_ | /| / /
___ ___ | / _ / _ __/ _ / / /_/ /_ |/ |/ /
_/_/ |_/_/ /_/ /_/ /_/ \____/____/|__/
Starting flask
* Serving Flask app "airflow.utils.serve_logs" (lazy loading)
* Environment: production
WARNING: This is a development server. Do not use it in a production
deployment.
Use a production WSGI server instead.
* Debug mode: off
[2021-07-09 16:58:19,818] {_internal.py:113} INFO - * Running on
http://0.0.0.0:8793/ (Press CTRL+C to quit)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
