This is an automated email from the ASF dual-hosted git repository.
eladkal pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 0c9c1cf94a Fix HiveToMySqlOperator's wrong docstring (#23316)
0c9c1cf94a is described below
commit 0c9c1cf94acc6fb315a9bc6f5bf1fbd4e4b4c923
Author: Kengo Seki <[email protected]>
AuthorDate: Thu Apr 28 22:25:21 2022 +0900
Fix HiveToMySqlOperator's wrong docstring (#23316)
Replace `metastore_conn_id` with `hiveserver2_conn_id`
---
airflow/providers/apache/hive/transfers/hive_to_mysql.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow/providers/apache/hive/transfers/hive_to_mysql.py
b/airflow/providers/apache/hive/transfers/hive_to_mysql.py
index c7817e5d69..65de4cc159 100644
--- a/airflow/providers/apache/hive/transfers/hive_to_mysql.py
+++ b/airflow/providers/apache/hive/transfers/hive_to_mysql.py
@@ -43,8 +43,8 @@ class HiveToMySqlOperator(BaseOperator):
:param mysql_table: target MySQL table, use dot notation to target a
specific database. (templated)
:param mysql_conn_id: source mysql connection
- :param metastore_conn_id: Reference to the
- :ref:`metastore thrift service connection id
<howto/connection:hive_metastore>`.
+ :param hiveserver2_conn_id: Reference to the
+ :ref:`Hive Server2 thrift service connection id
<howto/connection:hiveserver2>`.
:param mysql_preoperator: sql statement to run against mysql prior to
import, typically use to truncate of delete in place
of the data coming in, allowing the task to be idempotent (running
