[beam] branch nightly-refs/heads/master updated (3cd1f7f -> 74ab15c)

[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 3cd1f7f  [BEAM-13960] Add support for more types when converting from between row and proto (#16875)
     add fa32292  Bump org.mongodb:mongo-java-driver to 3.12.10
     add 75c25f0  Merge pull request #16989: [BEAM-5577] Bump org.mongodb:mongo-java-driver to 3.12.10
     add 1e4106b  [BEAM-13973] Link Dataproc Flink master URLs to the InteractiveRunner when FlinkRunner is used (#16904)
     add bdc3162  [BEAM-13925] Turn pr bot on for go prs (#16984)
     add 4136fb4  [BEAM-13964] Bump kotlin to 1.6.x (#16882)
     add e4bc643  Skipping flaky sad-path tests for Spanner changestreams
     add c0f9eff  Merge pull request #16993 from pabloem/fix-flake
     add da36470  Merge pull request #16906: [BEAM-13974] Handle idle Storage Api streams
     add 46c1fc7  Merge pull request #16562 from [BEAM-13051][D] Enable pylint warnings (no-name-in-module/no-value-for-parameter)
     add e210662  [BEAM-13925] A couple small pr-bot bug fixes (#16996)
     add 1294c2e  [BEAM-14029] Add getter, setter for target maven repo (#16995)
     add e234543  [BEAM-13903] Improve coverage of metricsx package (#16994)
     add 74ab15c  [BEAM-13892] Improve coverage of avroio package (#16990)

No new revisions were added by this update.

Summary of changes:
 .../{label_prs.yml => pr-bot-new-prs.yml}          |  32 +--
 .../{label_prs.yml => pr-bot-pr-updates.yml}       |  33 +--
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   2 +-
 examples/kotlin/build.gradle                       |   4 +-
 .../kotlin/common/WriteOneFilePerWindow.kt         |   5 +-
 .../examples/kotlin/cookbook/DistinctExample.kt    |   2 -
 .../beam/examples/kotlin/snippets/Snippets.kt      |   8 +-
 scripts/ci/pr-bot/processNewPrs.ts                 |   8 +
 scripts/ci/pr-bot/shared/persistentState.ts        |   8 +-
 sdks/go/data/tweet.avro                            | Bin 0 -> 275 bytes
 .../beam/core/runtime/metricsx/metricsx_test.go    | 184 +++++++++++++++-
 .../core/runtime/xlangx/expansionx/download.go     |  32 ++-
 .../runtime/xlangx/expansionx/download_test.go     |  66 ++++++
 sdks/go/pkg/beam/io/avroio/avroio_test.go          | 133 ++++++++++++
 .../bigquery/StorageApiFlushAndFinalizeDoFn.java   |  10 +
 .../bigquery/StorageApiWritesShardedRecords.java   |  94 +++++++--
 .../SpannerChangeStreamErrorTest.java              |   3 +
 sdks/python/apache_beam/io/avroio_test.py          |   8 +-
 sdks/python/apache_beam/io/filesystem.py           |   3 +-
 .../dataproc/dataproc_cluster_manager.py           | 153 ++++++++++++--
 .../dataproc/dataproc_cluster_manager_test.py      | 232 ++++++++++++++++++---
 .../runners/interactive/interactive_beam.py        |  13 +-
 .../runners/interactive/interactive_beam_test.py   |  17 +-
 .../runners/interactive/interactive_runner.py      |  23 +-
 .../runners/interactive/interactive_runner_test.py |  37 +++-
 .../apache_beam/runners/interactive/utils_test.py  |   3 -
 .../testing/load_tests/load_test_metrics_utils.py  |   9 +-
 27 files changed, 988 insertions(+), 134 deletions(-)
 copy .github/workflows/{label_prs.yml => pr-bot-new-prs.yml} (62%)
 copy .github/workflows/{label_prs.yml => pr-bot-pr-updates.yml} (57%)
 create mode 100644 sdks/go/data/tweet.avro
 create mode 100644 sdks/go/pkg/beam/io/avroio/avroio_test.go