[beam] branch nightly-refs/heads/master updated (74a2a1b071b -> 0e14f5181d8)

[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 74a2a1b071b Merge pull request #21872 from Standardizing output of WriteToBigQuery
     add 03ad079d963 Propogate error messages from GcsUtil (#22079)
     add df162c1e2fb Reenable Jenkins comment triggers (#22169)
     add e6391c5dc3c [Website] add refresh to page-nav.js
     add b613a1017bd Merge pull request #22076 [Website] Reverting deletion of refreshScrollSpy in PR 21731
     add 1c8955282cc Add `schema_options` and `field_options` on RowTypeConstraint (#22133)
     add 4c2236d2bf5 Declarative theming, Remove duplicate PlaygroundState for embedded page, Do not re-create CodeController on language change (#22147)
     add ad25b8774b5 Merge pull request #22158 from Declarative theming, Remove duplicate PlaygroundState for embedded page, Do not re-create CodeController on language change (#22147)
     add 493b8866cbe set timestamp when outputting finalize element
     add a23eca67718 Merge pull request #22119: [22188] Set timestamp when outputting finalize element
     add ed118a168bc Fix testKafkaIOReadsAndWritesCorrectlyInStreaming failing for kafka performance test
     add 692bbb1f6d4 Merge pull request #22186 from Fix testKafkaIOReadsAndWritesCorrectlyInStreaming failing for kafka performance test
     add 35a51a1a411 Fix Hadoop upload corrupted due to buffer reuse
     add ddc0777c3c1 Merge pull request #22177 from Fix Hadoop upload corrupted due to buffer reuse
     add 0e14f5181d8 Optimize locking in several critical-path methods (#22162)

No new revisions were added by this update.

Summary of changes:
 .../PhraseTriggeringPostCommitBuilder.groovy       |   6 +-
 .test-infra/jenkins/PostcommitJobBuilder.groovy    |  12 +-
 .../job_PerformanceTests_BigQueryIO_Java.groovy    |   3 +-
 .../job_PerformanceTests_FileBasedIO_IT.groovy     |   6 +-
 .../job_PerformanceTests_HadoopFormat.groovy       |   9 +-
 .../job_PerformanceTests_InfluxDBIO_IT.groovy      |   9 +-
 .../jenkins/job_PerformanceTests_JDBC.groovy       |   9 +-
 .../jenkins/job_PerformanceTests_KafkaIO_IT.groovy |   9 +-
 .../job_PerformanceTests_MongoDBIO_IT.groovy       |   9 +-
 .../jenkins/job_PerformanceTests_Python.groovy     |  11 +-
 .../jenkins/job_PerformanceTests_SQLIO_Java.groovy |   3 +-
 .test-infra/jenkins/job_PostCommit_Go.groovy       |   2 +-
 .test-infra/jenkins/job_PostCommit_Java.groovy     |   2 +-
 ...PostCommit_Java_ValidatesRunner_Dataflow.groovy |   2 +-
 .test-infra/jenkins/job_PostCommit_Python.groovy   |   2 +-
 ...ob_PostCommit_Python_MongoDBIO_Load_Test.groovy |   9 +-
 .../modules/editor/components/editor_textarea.dart |  68 +---
 .../modules/editor/components/editor_themes.dart   |   9 +-
 .../lib/modules/output/components/output.dart      |  18 +-
 .../frontend/lib/modules/sdk/models/sdk.dart       |  20 ++
 .../components/embedded_editor.dart                |   2 +-
 .../embedded_page_providers.dart                   | 106 ------
 .../embedded_playground_page.dart                  |   3 +-
 .../components/editor_textarea_wrapper.dart        |  29 +-
 .../components/playground_page_body.dart           |   3 +-
 .../components/playground_page_providers.dart      |  99 +++++-
 .../pages/playground/states/examples_state.dart    |  17 +-
 .../pages/playground/states/playground_state.dart  |  47 +--
 playground/frontend/lib/pages/routes.dart          |  20 +-
 playground/frontend/lib/playground_app.dart        |  10 +-
 playground/frontend/pubspec.lock                   |  10 +-
 playground/frontend/pubspec.yaml                   |   5 +-
 .../dataflow/BatchStatefulParDoOverridesTest.java  |   3 +-
 .../dataflow/DataflowPipelineTranslatorTest.java   |   3 +-
 .../beam/runners/dataflow/DataflowRunnerTest.java  |  29 +-
 .../beam/sdk/options/ProxyInvocationHandler.java   | 263 ++++++++------
 .../reflect/ByteBuddyDoFnInvokerFactory.java       |  31 +-
 .../sdk/transforms/reflect/DoFnSignatures.java     |  14 +-
 .../sdk/options/ProxyInvocationHandlerTest.java    | 123 +++++++
 .../extensions/gcp/storage/GcsPathValidator.java   |   6 +-
 .../beam/sdk/extensions/gcp/util/GcsUtil.java      |  20 +-
 .../sdk/extensions/gcp/options/GcpOptionsTest.java |   5 +-
 .../gcp/storage/GcsPathValidatorTest.java          |  14 +-
 .../beam/sdk/extensions/gcp/util/GcsUtilTest.java  |  79 +++++
 .../bigquery/StorageApiWritesShardedRecords.java   |  17 +-
 .../org/apache/beam/sdk/io/kafka/KafkaIOIT.java    |   4 +-
 sdks/python/apache_beam/io/hadoopfilesystem.py     |   4 +-
 sdks/python/apache_beam/typehints/row_type.py      |  39 ++-
 sdks/python/apache_beam/typehints/schemas.py       | 117 ++++++-
 sdks/python/apache_beam/typehints/schemas_test.py  | 379 ++++++++++++++++-----
 website/www/site/assets/js/page-nav.js             |   1 +
 51 files changed, 1159 insertions(+), 561 deletions(-)
 delete mode 100644 playground/frontend/lib/pages/embedded_playground/embedded_page_providers.dart