apache/beam

[Bug]: Fix num_storage_api_streams for batch

已关闭

#38,770 创建于 2026年6月2日

 (0 条评论) (0 个反应) (0 位负责人)Java (4,097 个派生)batch import
P2buggood first issuejavapython

仓库指标

星标
 (7,313 个星标)
PR 合并指标
 (平均合并 6天) (30 天内合并 243 个 PR)

描述

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

贡献者指南