Kafka Streams runner: merging windows and custom WindowFns
メンテナーはふだん 1 日以内に返信
まだ誰も着手していません。
評価
- 難易度
- 5/5
- 見積もり時間
- 1週間以上
- 初心者へのやさしさ
- 30/100
- issue の種類
- 機能追加
- 明瞭さ
- 説明が足りない
- 活発さ
- 静か
- 技術スタック
- java, kafka
調査の方向性
ReduceFnRunner、Kafka Streams runner の state backing、および GroupByKeyTest$WindowTests.testGroupByKeyMergingWindows と CombineTest$WindowingTests.testSessionsCombine で説明されている merging windows の動作から始めます。まず sickbayed session-window テストを再現してください。完了の条件は、merging windows が機能し、所有する SDK harness を通じたカスタム WindowFns の明確な経路が定義されていることです。
索引モデルが issue の本文から書いたものです。
説明
Two related windowing gaps in the Kafka Streams runner.
Merging windows. Session windows do not work. ReduceFnRunner drives merging through a merging window set that moves per-window state as windows merge, which the runner's state backing does not implement. GroupByKeyTest$WindowTests.testGroupByKeyMergingWindows and CombineTest$WindowingTests.testSessionsCombine are sickbayed for this.
Custom WindowFns. The runner rebuilds the standard WindowFns from their URNs and interprets them directly, which is what makes a pipeline from any SDK work. A WindowFn the user wrote is opaque to the runner and would have to be executed through the SDK harness that owns it.
Part of #18479.
- 主要言語
- Java
- スター
- 8.7k
- フォーク
- 4.7k
- 平均マージ
- 2日 7時間
- マージ済み PR（30日）
- 296
環境構築
- Dockerfile・Docker Compose ファイルなし
- プルリクエストのテンプレートあり
- コントリビューションガイドを読む
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- issue 番号を参照したプルリクエストを送ります。
apache/beam のほかの issue
-
[Feature Request]: Support Protobuf 7.x in Python SDK対応中かも @sofiathoren が 6 日前に担当しました。 オープンP2 python
難易度 2/5 1〜3時間 初心者へのやさしさ 62/100
メンテナーはふだん 1 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 68/100
apache/beam#39624 · リアクション 2 件 ·
メンテナーはふだん 1 日以内に返信
-
[Bug]: PubsubIO used in batch incorrect batch cutoff size対応中かも @1fanwang が 56 日前に担当しました。 オープンbug io P3 pinned pubsub
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
apache/beam#28011 · コメント 4 件 ·
メンテナーはふだん 1 日以内に返信
-
build P3 sub-task
難易度 1/5 1時間未満 初心者へのやさしさ 68/100
メンテナーはふだん 1 日以内に返信
-
bug gcp io java P3
難易度 1/5 1時間未満 初心者へのやさしさ 65/100
メンテナーはふだん 1 日以内に返信
似ている issue
-
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
QuicksilverMC/Argentum#31 ·
-
bug
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
navikt/mock-oauth2-server#1129 ·
メンテナーはふだん 1 日以内に返信
-
bug main ui
難易度 2/5 1〜3時間 初心者へのやさしさ 65/100
openhab/openhab-webui#4600 ·
メンテナーはふだん 4 日以内に返信
-
26.4 area: tags enhancement
難易度 2/5 1〜3時間 初心者へのやさしさ 68/100
メンテナーはふだん 1 日以内に返信
-
`DeepSeekChatModel` streaming returns no content when chunks have no `id`対応中かも @lejuho が今日担当しました。 オープンstatus: waiting-for-triage
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
spring-projects/spring-ai#7214 ·
メンテナーはふだん 2 日以内に返信