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

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


*** WARNING: tag nightly-master was modified! ***

    from 52ef994  (commit)
      to 4602fa4  (commit)
    from 52ef994  [BEAM-10937] Add first introductory notebook (#12892)
     add 27d9182  [BEAM-11027] Avoid excessive logging of ZetaSQL on Nexmark run
     add 6bf56f9  Merge pull request #13023 from 
iemejia/BEAM-11027-nexmark-zetasql
     add 15bd9ae  Update the test invocation cmd for poratble runner.
     add 2a16dd1  Merge pull request #13019 from boyuanzz/cmd_fix
     add 95161d2  [BEAM-11035] Pin versions of untrusted 3rd-party GitHub 
Actions
     add e4f4199  Merge pull request #13033 from 
TobKed/BEAM-11035-pin-third-party-github-actions
     add c56130b  [BEAM-11036] Add explanatory comment to PR if GA workflow 
gets cancelled
     add c288910  Merge pull request #13036 from 
TobKed/add-explanatory-comment-to-cancelled-ga-workflow
     add 7e8398b  Merge pull request #13001 from [BEAM-11041] Matching job 
creation and error messaged for BigQuery jobs between Java
     add 96a675c  [BEAM-10670, BEAM-11028] Ensure that 
UnboundedSourceAsSDFWrapperFn returns stop() when the UnboundedSource gets to 
BoundedWindow.TIMESTAMP_MAX_VALUE.
     add fe60b5b  [BEAM-10997] Close currentReader in trySplit
     add 3c28390  Merge pull request #13041 from lukecwik/beam10670.6
     add d9ff30b  [BEAM-11034] Avoid build-up of stateful garbage collection 
timers for GlobalWindow.
     add 4d4be21  Merge pull request #13032: [BEAM-11034] Avoid build-up of 
stateful garbage collection timers for GlobalWindow
     add f338284  Add python schema inference docs (#13005)
     add 4602fa4  [BEAM-11019] Fixing Go SDF progress reporting with multiple 
windows. (#13013)

No new revisions were added by this update.

Summary of changes:
 .github/workflows/cancel.yml                       |   3 +-
 .../runners/dataflow/worker/SimpleParDoFn.java     |  24 ++--
 sdks/go/pkg/beam/core/runtime/exec/pardo.go        |  54 +++++----
 sdks/go/pkg/beam/core/runtime/exec/sdf.go          |  69 ++++++++---
 sdks/go/pkg/beam/core/runtime/exec/sdf_test.go     |  78 ++++++++++++
 .../src/main/java/org/apache/beam/sdk/io/Read.java |  30 ++++-
 .../nexmark/src/main/resources/log4j.properties    |   3 +
 sdks/python/apache_beam/io/gcp/bigquery_tools.py   |  44 +++++--
 .../runners/portability/flink_runner_test.py       |   6 +-
 .../runners/portability/spark_runner_test.py       |   6 +-
 .../content/en/documentation/programming-guide.md  | 131 ++++++++++++++++++++-
 11 files changed, 369 insertions(+), 79 deletions(-)

Reply via email to