matt
matt

Reputation: 1

Airflow jdbc unable to find class driver

I am unable to set up a jdbc connection in Airflow. I keep receiving the error class not found.

My connection looks like the following: airflow_jdbc_conn

Here is the error i receive in Airflow when testing: driver_error

My connection credentials are all correct and I can connect with SQLWorkbenchJ. Also I have tried different redshift jdbc drivers and class names.

/Users/mkleinert/anaconda/lib/python2.7/site-packages/airflow/utils/helpers.py:406: DeprecationWarning: Importing PythonOperator directly from has been deprecated. Please import from '.[operator_module]' instead. Support for direct imports will be dropped entirely in Airflow 2.0. DeprecationWarning) /Users/mkleinert/anaconda/lib/python2.7/site-packages/airflow/utils/helpers.py:406: DeprecationWarning: Importing MsSqlOperator directly from has been deprecated. Please import from '.[operator_module]' instead. Support for direct imports will be dropped entirely in Airflow 2.0. DeprecationWarning) /Users/mkleinert/anaconda/lib/python2.7/site-packages/airflow/utils/helpers.py:406: DeprecationWarning: Importing FTPHook directly from has been deprecated. Please import from '.[operator_module]' instead. Support for direct imports will be dropped entirely in Airflow 2.0. DeprecationWarning) /Users/mkleinert/anaconda/lib/python2.7/site-packages/airflow/utils/helpers.py:406: DeprecationWarning: Importing JdbcOperator directly from has been deprecated. Please import from '.[operator_module]' instead. Support for direct imports will be dropped entirely in Airflow 2.0. DeprecationWarning) /Users/mkleinert/anaconda/lib/python2.7/site-packages/airflow/models.py:1927: PendingDeprecationWarning: Invalid arguments were passed to JdbcOperator. Support for passing such arguments will be dropped in Airflow 2.0. Invalid arguments were: *args: () **kwargs: {'conn_id': 'mssql_etl'} category=PendingDeprecationWarning

Upvotes: 0

Views: 2105

Answers (1)

Breathe
Breathe

Reputation: 724

Can you show the webserver log? Especially when you start it? Is the jaydebeapi package installed?

(pip install jaydebeapi)

Upvotes: 0

Related Questions