apache/beam

Test Spark streaming pipelines with maxRecordsPerBatch

Open

#18,354 opened on 2022年6月3日

GitHub で見る
 (0 comments) (0 reactions) (0 assignees)Java (4,097 forks)batch import
P3good first issuerunnerssparktests

Repository metrics

Stars
 (7,313 stars)
PR merge metrics
 (平均マージ 6d) (30d で 243 merged PRs)

説明

Add tests for Spark streaming pipelines with maxRecordsPerBatch configured in SparkPipelineOptions.

Imported from Jira BEAM-2127. Original Jira may contain additional context. Reported by: aviemzur.

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