apache/beam

[Bug]: Fix num_storage_api_streams for batch

クローズ

#38,770 opened on 2026/06/02

 (0 件のコメント) (0 件のリアクション) (0 人の担当者)Java (4,097 件のフォーク)batch import
P2buggood first issuejavapython

Repository metrics

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

説明

What happened?

Fix handling https://beam.apache.org/releases/pydoc/2.73.0/apache_beam.io.gcp.bigquery.html#apache_beam.io.gcp.bigquery.WriteToBigQuery num_storage_api_streams for batch.

  1. update documentation and remove limitation about streaming only
  2. handle translation to work also on bounded pipelines https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryStorageWriteApiSchemaTransformProvider.java#L186

Issue Priority

Priority: 2 (default / most bugs should be filed as P2)

Issue Components

  • Component: Python SDK
  • Component: Java SDK
  • Component: Go SDK
  • Component: Typescript SDK
  • Component: IO connector
  • Component: Beam YAML
  • Component: Beam examples
  • Component: Beam playground
  • Component: Beam katas
  • Component: Website
  • Component: Infrastructure
  • Component: Spark Runner
  • Component: Flink Runner
  • Component: Prism Runner
  • Component: Twister2 Runner
  • Component: Hazelcast Jet Runner
  • Component: Google Cloud Dataflow Runner

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