[beam] branch nightly-refs/heads/master updated (cff9ccd86b3 -> 07bbd2bf403)

[gi...@apache.org]

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 cff9ccd86b3 [BEAM-13204] Fix website bug where code tabs do not appear if the default language is not available (#17379)
     add 4b9ea7415f1 [BEAM-14307] Fix Slow Side input pattern bug in sample
     add 3ce67b2690d Merge pull request #17371 from [BEAM-14307] Fix Slow Side input pattern bug in sample
     add 3fbda804317 [BEAM-14316] Introducing KafkaIO.Read implementation compatibility testing (#16909)
     add 892271aa9db [BEAM-14290] Address staticcheck warnings in the reflectx package (#17373)
     add 1a23e13e197 [BEAM-14302] Simply bools in fn.go, genx_test.go (#17356)
     add e4cfeec328e [BEAM-14251] add output_coder_override to ExpansionRequest
     add 3e5f4ae0b67 remove null
     add 9a45244e767 better error msg
     add 386ae509856 update from comments
     add 07bbd2bf403 Merge pull request #17280 from ihji/BEAM-14251

No new revisions were added by this update.

Summary of changes:
 .../apache/beam/examples/snippets/Snippets.java    |  38 ++--
 .../job_management/v1/beam_expansion_api.proto     |   6 +
 .../beam/runners/core/construction/External.java   |  65 +++++-
 sdks/go/pkg/beam/core/graph/fn.go                  |   2 +-
 sdks/go/pkg/beam/core/runtime/genx/genx_test.go    |   5 +-
 sdks/go/pkg/beam/core/util/reflectx/call.go        |   4 +-
 sdks/go/pkg/beam/core/util/reflectx/call_test.go   |   4 +-
 sdks/go/pkg/beam/core/util/reflectx/calls.go       |   2 +
 sdks/go/pkg/beam/core/util/reflectx/calls.tmpl     |   2 +
 sdks/go/pkg/beam/core/util/reflectx/types.go       |   3 +-
 sdks/go/pkg/beam/core/util/reflectx/types_test.go  |   3 +-
 .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java |  43 ++--
 .../KafkaIOReadImplementationCompatibility.java    | 242 +++++++++++++++++++++
 ...KafkaIOReadImplementationCompatibilityTest.java | 146 +++++++++++++
 .../org/apache/beam/sdk/io/kafka/KafkaIOTest.java  |  15 +-
 .../runners/portability/expansion_service.py       |  11 +
 .../runners/portability/expansion_service_test.py  |  23 ++
 sdks/python/apache_beam/transforms/external.py     |  18 +-
 .../python/apache_beam/transforms/external_test.py |  30 +++
 19 files changed, 594 insertions(+), 68 deletions(-)
 create mode 100644 sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIOReadImplementationCompatibility.java
 create mode 100644 sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOReadImplementationCompatibilityTest.java