diff --git a/airflow/providers/alibaba/cloud/operators/analyticdb_spark.py b/airflow/providers/alibaba/cloud/operators/analyticdb_spark.py index 106f7583cb717..1ea8f8a970aa6 100644 --- a/airflow/providers/alibaba/cloud/operators/analyticdb_spark.py +++ b/airflow/providers/alibaba/cloud/operators/analyticdb_spark.py @@ -131,7 +131,7 @@ def __init__( ) -> None: super().__init__(**kwargs) - self.spark_params = { + spark_params = { "sql": sql, "conf": conf, "driver_resource_spec": driver_resource_spec, @@ -139,7 +139,7 @@ def __init__( "num_executors": num_executors, "name": name, } - + self.spark_params = spark_params self._cluster_id = cluster_id self._rg_name = rg_name @@ -196,7 +196,7 @@ def __init__( ) -> None: super().__init__(**kwargs) - self.spark_params = { + spark_params = { "file": file, "class_name": class_name, "args": args, @@ -210,7 +210,7 @@ def __init__( "archives": archives, "name": name, } - + self.spark_params = spark_params self._cluster_id = cluster_id self._rg_name = rg_name