Enable the Comet in-memory cache (`InMemoryTableScan`) by default

オープン
#7,425 コメント 0 件 リアクション 0 件 担当者 0 名 GitHub で見る

メンテナーはふだん 2 日以内に返信

まだ誰も着手していません。

評価

難易度
5/5
見積もり時間
1週間以上
初心者へのやさしさ
8/100
issue の種類
機能追加
明瞭さ
おおむね明確
活発さ
活発
技術スタック
rust, scala, spark

調査の方向性

The change centres on the spark.comet.exec.inMemoryCache.enabled setting and the InMemoryTableScanExec path that the issue describes; the payload names no specific file or test. Read the linked audit epic #6834 and the executor-abort report #7305 before anything else, since both gate the change. Done means the default flips to on, the Spark 3.4 abort is resolved, and a performance comparison against Spark's cache is recorded.

索引モデルが issue の本文から書いたものです。

説明

enhancement requires-triage
What is the problem the feature request solves?

Cached DataFrames are common in batch ETL. Comet's Arrow cache (spark.comet.exec.inMemoryCache.enabled) is experimental and off by default. With it off, a cached relation is read through Spark's InMemoryTableScanExec, and the operators above it can't run natively.

Describe the potential solution

Close the remaining correctness and stability items, then turn the cache on by default:

  • the in-memory cache audit epic (#6834)
  • the Spark 3.4 executor abort with the cache enabled (#7305)
  • memory accounting and spill behavior for large cached relations
  • a performance check against Spark's cache on wide and narrow schemas
Additional context

Because the serializer has to be installed at startup, the default has to be decided before the session starts, not per query.

主要言語
Scala
スター
1.3k
フォーク
414
平均マージ
3日 5時間
マージ済み PR(30日)
210

環境構築

はじめの一歩

  1. issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
  2. 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
  3. リポジトリをフォークし、ブランチを切って変更します。
  4. issue 番号を参照したプルリクエストを送ります。

apache/datafusion-comet のほかの issue

apache/datafusion-comet の issue をすべて見る

似ている issue

Scala の issue をもっと見る

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。