You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Siddharth Anand (JIRA)" <ji...@apache.org> on 2018/09/14 01:05:00 UTC
[jira] [Closed] (AIRFLOW-841) "OperationalError: Couldn't log in: a
socket error occurred" when using web UI
[ https://issues.apache.org/jira/browse/AIRFLOW-841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Siddharth Anand closed AIRFLOW-841.
-----------------------------------
Resolution: Cannot Reproduce
> "OperationalError: Couldn't log in: a socket error occurred" when using web UI
> ------------------------------------------------------------------------------
>
> Key: AIRFLOW-841
> URL: https://issues.apache.org/jira/browse/AIRFLOW-841
> Project: Apache Airflow
> Issue Type: Bug
> Components: celery, executor, scheduler, ui
> Reporter: abhijeet dada mote
> Priority: Major
> Labels: beginner, triaged
> Attachments: airflow.cfg, hello.py, print_range.py
>
>
> Hi All,
> I am getting following error when I am trying to run my workflow using UI.
> Can anyone help me to resolve this problem?
> *OperationalError: Couldn't log in: a socket error occurred*
> {code}
> Traceback (most recent call last):
> File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1817, in wsgi_app
> response = self.full_dispatch_request()
> File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1477, in full_dispatch_request
> rv = self.handle_user_exception(e)
> File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1381, in handle_user_exception
> reraise(exc_type, exc_value, tb)
> File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1475, in full_dispatch_request
> rv = self.dispatch_request()
> File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1461, in dispatch_request
> return self.view_functions[rule.endpoint](**req.view_args)
> File "/usr/local/lib/python2.7/dist-packages/flask_admin/base.py", line 68, in inner
> return self._run_view(f, *args, **kwargs)
> File "/usr/local/lib/python2.7/dist-packages/flask_admin/base.py", line 367, in _run_view
> return fn(self, *args, **kwargs)
> File "/usr/local/lib/python2.7/dist-packages/flask_login.py", line 755, in decorated_view
> return func(*args, **kwargs)
> File "/usr/local/lib/python2.7/dist-packages/airflow/www/utils.py", line 118, in wrapper
> return f(*args, **kwargs)
> File "/usr/local/lib/python2.7/dist-packages/airflow/www/utils.py", line 167, in wrapper
> return f(*args, **kwargs)
> File "/usr/local/lib/python2.7/dist-packages/airflow/www/views.py", line 989, in run
> executor.heartbeat()
> File "/usr/local/lib/python2.7/dist-packages/airflow/executors/base_executor.py", line 99, in heartbeat
> self.execute_async(key, command=command, queue=queue)
> File "/usr/local/lib/python2.7/dist-packages/airflow/executors/celery_executor.py", line 66, in execute_async
> args=[command], queue=queue)
> File "/usr/local/lib/python2.7/dist-packages/celery/app/task.py", line 535, in apply_async
> **options
> File "/usr/local/lib/python2.7/dist-packages/celery/app/base.py", line 737, in send_task
> amqp.send_task_message(P, name, message, **options)
> File "/usr/local/lib/python2.7/dist-packages/celery/app/amqp.py", line 558, in send_task_message
> **properties
> File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 181, in publish
> exchange_name, declare,
> File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 527, in _ensured
> errback and errback(exc, 0)
> File "/usr/lib/python2.7/contextlib.py", line 35, in __exit__
> self.gen.throw(type, value, traceback)
> File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 419, in _reraise_as_library_errors
> sys.exc_info()[2])
> File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 414, in _reraise_as_library_errors
> yield
> File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 515, in _ensured
> reraise_as_library_errors=False,
> File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 405, in ensure_connection
> callback)
> File "/usr/local/lib/python2.7/dist-packages/kombu/utils/functional.py", line 333, in retry_over_time
> return fun(*args, **kwargs)
> File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 261, in connect
> return self.connection
> File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 802, in connection
> self._connection = self._establish_connection()
> File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 757, in _establish_connection
> conn = self.transport.establish_connection()
> File "/usr/local/lib/python2.7/dist-packages/kombu/transport/librabbitmq.py", line 132, in establish_connection
> conn = self.Connection(**opts)
> File "/usr/local/lib/python2.7/dist-packages/librabbitmq/__init__.py", line 199, in __init__
> self.connect()
> OperationalError: Couldn't log in: a socket error occurred
> {code}
> I have made the changes in _/home/ubuntu/airflow/airflow.cfg_ file.
> Commented the default setting to new one(changes are displayed below).
> {code}
> # executor = SequentialExecutor
> executor = CeleryExecutor
> # sql_alchemy_conn = sqlite:////home/ubuntu/airflow/airflow.db
> sql_alchemy_conn = postgresql+psycopg2://airflow:airflow_demo@localhost:5432/airflow_demo
> # broker_url = sqla+mysql://airflow:airflow@localhost:3306/airflow
> broker_url = amqp://airflow:airflow_demo@localhost:5672/airflow_demo
> # celery_result_backend = db+mysql://airflow:airflow@localhost:3306/airflow
> celery_result_backend = db+postgresql://airflow:airflow_demo@localhost:5432/airflow_demo
> {code}
> To perform the activity through UI:
> # I have installed Celery(because UI activity only works with celery executor)
> # Installed rabitmq and created the user and given the permissions.
> # Installed postgresql and dependent packages, added required URL string.
> # I also have created the required user with permissions using rabitmqadmin.
> # But facing the error which is mentioned above.
> Is there any dependency of flower service on airflow. The dags which I have created using CeleryExecutor is working fine through command line but not working in UI.
> Following is the configuration file _/home/ubuntu/airflow/airflow.cfg_ [^airflow.cfg]
> Following is the dag which I have created: [^hello.py], [^print_range.py]
> [~nickt], [~criccomini], [~maxime.beauchemin@apache.org]. Can you please help me to resolve this issue.
> Thanks in Advance,
> Abhijeet
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)