親愛なるStackoverflowメンバー、
気流を使用してクラスタを起動し、スパークジョブを実行して終了するDAGをスケジュールしようとしています。私はこの例に従うことを試みた: https://insight.io/github.com/apache/incubator-airflow/blob/master/airflow/contrib/example_dags/example_emr_job_flow_automatic_steps.py
をそれは私にエラーを与えた:airflow.exceptions.AirflowException:定義されていないemr_default
conn_id
これがない場合、私はおそらく(私を修正してくださいemr_default
が設定されている必要があり ケース)。誰もがこれを前に試して、それを設定する方法のヒントを教えてもらえますか?気流のウェブサイトは、emr接続に多すぎるものを提供しません:http://pythonhosted.org/airflow/configuration.html?highlight=connection#connections
エアフローでemr_defaultを設定する方法
ありがとう!
おかげ@Himをしたい任意の接続を追加する>
Create
、私は問題を発見し、私は古いバージョンを使用していた、その後1.8にアップグレード変数として前にemr_defaultはありませんでした。 – Chengzhi