2017-06-26 7 views
1

親愛なる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を設定する方法

ありがとう!

答えて

0

気流UIで、Admin - > Connectionsタブに移動し、emr_default行の値を編集します。

+0

おかげ@Himをしたい任意の接続を追加する>Create、私は問題を発見し、私は古いバージョンを使用していた、その後1.8にアップグレード変数として前にemr_defaultはありませんでした。 – Chengzhi

0

@彼は言ったように、気流を編集することができます。 しかし、あなたがemr_defaultを見つけることができない場合、あなたはAdminに行くことができます - >Connections - あなたは

+0

ありがとうございます。@ zhongjiajieですが、すでに別の回答を受け入れていますが、依然としてあなたの貢献に感謝したいと思います。 – Chengzhi

+0

問題を解決できることがわかりました – zhongjiajie

関連する問題