[beam] branch master updated (117123c -> 2aa4da0)

[da...@apache.org]

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

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


    from 117123c  [BEAM-10652] Allow Clustering without Partition in BigQuery (#16578)
     add 2aa4da0  [BEAM-13857] Add K:V flags for expansion service jars and addresses to Go ITs. (#16908)

No new revisions were added by this update.

Summary of changes:
 sdks/go/test/integration/expansions.go             | 119 ++++++++++++++
 sdks/go/test/integration/expansions_test.go        | 179 +++++++++++++++++++++
 sdks/go/test/integration/flags.go                  |  86 +++++++++-
 sdks/go/test/integration/internal/jars/jars.go     |  64 ++++++++
 .../go/test/integration/internal/jars/proc.go      |  14 +-
 .../cluster_unix.go => internal/jars/proc_unix.go} |  24 ++-
 .../test/integration/internal/jars/run_nonunix.go  |  54 +++++++
 sdks/go/test/integration/internal/jars/run_unix.go |  65 ++++++++
 .../integration/internal/ports/ports.go}           |  18 ++-
 9 files changed, 593 insertions(+), 30 deletions(-)
 create mode 100644 sdks/go/test/integration/expansions.go
 create mode 100644 sdks/go/test/integration/expansions_test.go
 create mode 100644 sdks/go/test/integration/internal/jars/jars.go
 copy learning/katas/go/introduction/hello_beam/hello_beam/pkg/task/task.go => sdks/go/test/integration/internal/jars/proc.go (83%)
 copy sdks/go/test/integration/{io/xlang/kafka/cluster_unix.go => internal/jars/proc_unix.go} (66%)
 create mode 100644 sdks/go/test/integration/internal/jars/run_nonunix.go
 create mode 100644 sdks/go/test/integration/internal/jars/run_unix.go
 copy sdks/go/{pkg/beam/core/util/protox/protox.go => test/integration/internal/ports/ports.go} (69%)