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

Posted to commits@beam.apache.org by ro...@apache.org on 2020/08/21 16:46:01 UTC

[beam] branch master updated (209bc21 -> 0040865)

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

robinyqiu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 209bc21  Merge pull request #12650 from alanmyrvold/licensesGo
     add 0040865  Propagate BigQuery streaming insert throttled time to Dataflow worker in Java SDK (#12403)

No new revisions were added by this update.

Summary of changes:
 .../dataflow/worker/BatchModeExecutionContext.java | 28 ++++++++++++++--------
 .../dataflow/worker/StreamingDataflowWorker.java   | 17 +++++++++++--
 .../worker/BatchModeExecutionContextTest.java      |  8 +++----
 .../gcp/util/RetryHttpRequestInitializer.java      |  6 ++---
 .../sdk/io/gcp/bigquery/BigQueryServicesImpl.java  | 15 ++++++++++++
 .../beam/sdk/io/gcp/datastore/DatastoreV1.java     |  6 ++---
 6 files changed, 58 insertions(+), 22 deletions(-)