Comet Native Executors: support writes
メンテナーはふだん 1 日以内に返信
@andygrove がすでに取り組んでいます。
2026年11月1日 から。
評価
- 難易度
- 5/5
- 見積もり時間
- 1週間以上
- 初心者へのやさしさ
- 40/100
- issue の種類
- 機能追加
- 明瞭さ
- おおむね明確
- 活発さ
- 活発
- 技術スタック
- scala, spark
調査の方向性
Start by reading CometNativeExecutors.applies and the existing IcebergWriteExec and IcebergCommitExec flow, then review the context in issues #7288 and #7289. Trace how write commands are currently delegated and how written-file metadata could reach the driver for commit. Done means supported write commands, including INSERT, CTAS, and DataFrame.write, execute on the native executor cluster and commit on the driver.
索引モデルが issue の本文から書いたものです。
説明
What is the problem the feature request solves?
A Comet Native Executor cluster (#7289) only runs queries. A plan with a DataWritingCommandExec or a V2 write command is left to Spark, so INSERT, CTAS and DataFrame.write don't run on the cluster.
Describe the potential solution
Write the files on the executors and commit on the driver, like Comet's split Iceberg writer (IcebergWriteExec and IcebergCommitExec): the cluster returns the written files' metadata as the query's result, and the driver runs the commit protocol.
Additional context
#7288 lists writes as out of scope at first. CometNativeExecutors.applies skips write commands today.
Part of #7288.
Willingness to contribute
Yes. I can contribute this feature independently.
- 主要言語
- Scala
- スター
- 1.3k
- フォーク
- 405
- 平均マージ
- 2日 22時間
- マージ済み PR（30日）
- 298
環境構築
- Dockerfile・Docker Compose ファイルなし
- プルリクエストのテンプレートあり
- コントリビューションガイドを読む
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- issue 番号を参照したプルリクエストを送ります。
apache/datafusion-comet のほかの issue
-
area:ci enhancement priority:low requires-triage
難易度 2/5 1〜3時間 初心者へのやさしさ 74/100
apache/datafusion-comet#7319 · コメント 1 件 ·
メンテナーはふだん 1 日以内に返信
-
area:ci bug priority:low requires-triage
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
apache/datafusion-comet#7315 ·
メンテナーはふだん 1 日以内に返信
-
requires-triage
難易度 2/5 1〜3時間 初心者へのやさしさ 72/100
apache/datafusion-comet#7240 ·
メンテナーはふだん 1 日以内に返信
-
bug priority:low
難易度 2/5 1〜3時間 初心者へのやさしさ 82/100
apache/datafusion-comet#7176 ·
メンテナーはふだん 1 日以内に返信
-
docs: update Scala comments that reference the removed iceberg-writes.md page対応中かも @Abhishek-Mohan が 3 日前に担当しました。 オープンenhancement
難易度 1/5 1〜3時間 初心者へのやさしさ 83/100
apache/datafusion-comet#7101 ·
メンテナーはふだん 1 日以内に返信
apache/datafusion-comet の issue をすべて見る
似ている issue
-
Traffic event delivered/rejected counters appear swapped in TrafficStateController.updateWithReceiptオープン
難易度 2/5 1〜3時間 初心者へのやさしさ 65/100
digital-asset/canton#705 ·
メンテナーはふだん 2 日以内に返信
-
easy first-contributor first-contributors good first issue help wanted scala up-for-grabs
難易度 2/5 1〜3時間 初心者へのやさしさ 88/100
fork-commit-merge/fork-commit-merge#8457 ·
メンテナーはふだん 1 日以内に返信
-
[GC] Empty or non-numeric GC_*_HEAP_SIZE reads out of bounds or uses an uninitialised size対応中かも @oluies が 1 日前に担当しました。 オープン
難易度 2/5 1〜3時間 初心者へのやさしさ 75/100
scala-native/scala-native#5177 ·
メンテナーはふだん 1 日以内に返信
-
good first issue
難易度 1/5 1時間未満 初心者へのやさしさ 78/100
promovolve/promovolve#358 ·
メンテナーはふだん 1 日以内に返信
-
難易度 1/5 1時間未満 初心者へのやさしさ 95/100
svroonland/zio-kinesis#1431 ·