You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by gi...@apache.org on 2023/05/30 05:26:19 UTC

[beam] branch nightly-refs/heads/master updated (68d991aef26 -> fbeae980e93)

This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 68d991aef26 [Flink][KafkaIO] Finalize checkpoints during stop/drain scenario (#26883)
     add fbeae980e93 Merge pull request #26919: warn if BigQuery failed rows collection is not processed

No new revisions were added by this update.

Summary of changes:
 .../beam/runners/dataflow/DataflowRunner.java      | 56 ++++++++++++++
 .../beam/runners/dataflow/DataflowRunnerTest.java  | 89 +++++++++++++++++++++-
 .../beam/sdk/io/gcp/bigquery/BigQueryIO.java       |  4 +-
 .../beam/sdk/io/gcp/bigquery/StorageApiLoads.java  |  5 ++
 .../sdk/io/gcp/bigquery/StreamingWriteTables.java  |  8 +-
 5 files changed, 157 insertions(+), 5 deletions(-)