apache/airflow

SparkKubernetesOperator to support arguments

Open

#16,728 opened on 2021年6月30日

GitHub で見る
 (9 comments) (0 reactions) (0 assignees)Python (16,781 forks)batch import
area:providersgood first issuekind:documentationkind:featureprovider:cncf-kubernetes

Repository metrics

Stars
 (44,809 stars)
PR merge metrics
 (平均マージ 7d 18h) (30d で 834 merged PRs)

説明

Need an option ,when triggering a dag via airflow web ui, to pass JSON arguments to SparkKubernetesOperator.

Currently I don't see a way to do it as, SparkKubernetesOperator accepts application.yaml only.

コントリビューターガイド

調査方針
まず、Airflow コードベース内の `airflow/providers/apache/spark/operators/spark kubernetes.py` に SparkKubernetesOperator クラスを探します。現在のオペレーターが `application.yaml` をどのように処理し、どこで引数を注入できるかを調べます。オペレーターは、JSON 文字列または辞書を受け取り、それを SparkApplication 仕様にレンダリングする新しいパラメータを必要とするかもしれません。既存の JSON 引数を処理する Airflow オペレーターをパターンとして確認します。提案されたアプローチやメンテナのフィードバックについて、issue コメントを確認します。
技術スタック
python
領域
backend
Issue 種別
機能
難度新しい貢献者にとっての実装難度です。1 は非常に小さな変更、5 は専門的な作業です。
3
推定時間経験ある貢献者が調査、実装、テスト、pull request 準備にかけるおおよその時間範囲です。
半日
活動状況Issue が今どれだけ取り組みやすいかを示します。新しい、活発、古い、ブロック中、またはメンテナー入力待ちなどです。
アクティブ
明確さ期待される変更、受け入れ条件、次の手順がどれだけ明確かを示します。
明確
前提条件
AirflowPython
初心者向け度初回貢献者にどれだけ取り組みやすいかを 1-100 で推定したスコアです。
60