[beam] tag nightly-master updated (af59192 -> 80da0ec)

[gi...@apache.org]

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 af59192  (commit)
      to 80da0ec  (commit)
    from af59192  fix confusing function def (#15120)
     add b6bd71b  [BEAM-12619] Swap LinkedBlockingQueue to ArrayBlockingQueue for minor perf improvement
     add 80bff62  fixup! Fix spotbugs warning
     add f5b91b9  [BEAM-12619] Swap LinkedBlockingDeque to ArrayBlockingQueue for minor perf improvement
     add 5ad92c6  [BEAM-12759] ORDER BY then SELECT
     add c3bc467  Merge pull request #15334 from apilloud/orderby
     add 80ee586  Add AWS services as a runtime dependency to support S3
     add bfd7b17  [BEAM-12739] Add AWS services as a runtime dependency to Flink Job Server to support S3
     add de7e7d3  [BEAM-7745] Avoid uncached state fetches for streaming side-inputs (#15235)
     add be92829  [BEAM-12609] Make type parameter part of PushdownProjector interface.
     add 9cdf661  Merge pull request #15297 from ibzib/BEAM-12609-t
     add 6b5f298  [BEAM-12504] Make CreateTransaction wait on input signal
     add 6774062  Merge pull request #15048 from [BEAM-12504] Make SpannerIO.ConnectTransaction wait on input signal
     add ec36bca  [BEAM-12479] Fixes UnsupportedOperationException
     add efba565  Merge pull request #14997 from [BEAM-12479] Fixes UnsupportedOperationException
     add 153d35f  redundant build
     add ecb8cbb  Merge pull request #15336: [BEAM-12763] Remove redundant build from copy path in copyJavaThirdPartyLicenses rule
     add 80da0ec  [BEAM-11088] TestStream utility and testing improvements (#15320)

No new revisions were added by this update.

Summary of changes:
 runners/flink/job-server/flink_job_server.gradle   |   3 +-
 .../worker/StreamingSideInputDoFnRunner.java       |   1 +
 .../dataflow/worker/StreamingSideInputFetcher.java |   4 +
 sdks/go/pkg/beam/testing/teststream/teststream.go  |  27 ++++-
 .../pkg/beam/testing/teststream/teststream_test.go |  58 +++++++++-
 sdks/go/test/integration/integration.go            |   2 +
 sdks/go/test/integration/primitives/teststream.go  | 119 +++++++++++++++++++--
 .../test/integration/primitives/teststream_test.go |  38 ++++++-
 sdks/java/container/common.gradle                  |   2 +-
 .../beam/sdk/schemas/io/PushdownProjector.java     |   4 +-
 .../provider/SchemaIOTableProviderWrapper.java     |  10 +-
 .../provider/TestSchemaIOTableProviderWrapper.java |   7 +-
 .../LimitOffsetScanToOrderByLimitConverter.java    |   7 +-
 .../sql/zetasql/ZetaSqlDialectSpecTest.java        |  14 +++
 .../fn/harness/logging/BeamFnLoggingClient.java    |  17 ++-
 .../beam/sdk/io/gcp/bigquery/BigQueryUtils.java    |   6 +-
 .../sdk/io/gcp/spanner/CreateTransactionFn.java    |  12 ++-
 .../apache/beam/sdk/io/gcp/spanner/SpannerIO.java  |  24 +++--
 .../sdk/io/gcp/bigquery/BigQueryUtilsTest.java     |  79 +++++++++++---
 19 files changed, 370 insertions(+), 64 deletions(-)