apache/airflow

SparkKubernetesOperator to support arguments

オープン

#16,728 opened on 2021/06/30

GitHub で見るコントリビューターガイド
 (9 件のコメント) (0 件のリアクション) (0 人の担当者)Python (16,781 件のフォーク)batch import
area:providersgood first issuekind:documentationkind:featureprovider:cncf-kubernetes

Repository metrics

Stars
 (44,809 個のスター)
PR merge metrics
 (PR metrics pending)

説明

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