[beam] branch nightly-refs/heads/master updated (25ca4f0fddd -> cc48828cc83)

[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 25ca4f0fddd Followup sharding javaPostCommit (#22081)
     add b1eae0b572f remove mention of dill in release notes as it's not relevant. (#22087)
     add 157fd3ea1e2 [#21634] Add comments on FieldValueGetter. (#21982)
     add 340b4217639 Bump google.golang.org/api from 0.85.0 to 0.86.0 in /sdks (#22092)
     add 40614bd5625 [Website] add scroll-spy to body in case-studies/baseof.html
     add 4bdc6733db5 Merge pull request #21984 from [Website] fix all case-studies right nav menu
     add 62208c5da28 [BEAM-6597] Replace ProgressRequestCallback with BundleProgressReporter (#22005)
     add ffa46b330fb [Go SDK] Go Lint fixes  (#21967)
     add 4a6579d2193 Fix #21869: Close GRPC connections on cancel (#21874)
     add cfa9f68cadf Add FlatMap(<builtin>) known issue to 2.40.0 blog (#22101)
     add fd5e2f4f01a [BEAM-14347] Update docs to prefer generic registration functions (#17799)
     add 0b6acc7bebc Merge pull request #21752 from Feature/beam 13852 reimplement with dynamic read
     add f2dcdcf4c4b Change wording of Pytorch LM example (#22099)
     add 9ffeced5f24 Fix missing model_params in Pytorch docstring  (#22100)
     add d69fcb7a3b5 Add an abstract layer for analytics, fix logging change of snippet, fix logging cancelling, fix logging link following (#22012)
     add de04604aee0 Merge pull request #22013 from [Playground] Fix analytics for snippet changing, cancelling, and link following (#22012)
     add ca112ad949f Test and fix FlatMap(<builtin>) issue (#22104)
     add 07ed486d653 Fix InputStream on platform with 4 bytie long (#22107)
     add 5d7fd3214d9 Projection Pushdown optimizer on by default
     add cc48828cc83 Merge pull request #22049: Projection Pushdown optimizer on by default

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         |   4 +-
 .../lib/modules/analytics/analytics_events.dart    |   1 +
 .../lib/modules/analytics/analytics_service.dart   | 122 +-----
 ..._service.dart => google_analytics_service.dart} |  36 +-
 .../example_list/expansion_panel_item.dart         |   2 +-
 .../components/embedded_appbar_title.dart          |  16 +-
 .../components/editor_textarea_wrapper.dart        |  13 +-
 .../components/playground_page_providers.dart      |   3 +-
 playground/frontend/lib/utils/analytics_utils.dart |  10 +-
 .../org/apache/beam/runners/flink/FlinkRunner.java |   3 +-
 .../beam/runners/dataflow/DataflowRunner.java      |   3 +-
 .../org/apache/beam/runners/spark/SparkRunner.java |   3 +-
 sdks/go.mod                                        |  10 +-
 sdks/go.sum                                        |  15 +-
 sdks/go/examples/snippets/04transforms.go          |  41 +-
 sdks/go/pkg/beam/core/runtime/harness/datamgr.go   |   7 +-
 sdks/go/pkg/beam/core/runtime/harness/harness.go   |   8 +-
 sdks/go/pkg/beam/core/runtime/harness/init/init.go |   7 +-
 sdks/go/pkg/beam/core/runtime/harness/logging.go   |  24 +-
 sdks/go/pkg/beam/core/runtime/harness/sampler.go   |   2 +
 sdks/go/pkg/beam/core/runtime/harness/statemgr.go  |   9 +-
 .../pkg/beam/core/runtime/harness/statemgr_test.go |   2 +-
 .../pkg/beam/core/runtime/harness/worker_status.go |   5 +-
 sdks/go/test/integration/io/fhirio/fhirio_test.go  |  12 +-
 .../integration/io/xlang/bigquery/bigquery_test.go |  18 +-
 .../apache/beam/sdk/schemas/FieldValueGetter.java  |   1 +
 .../main/java/org/apache/beam/sdk/values/Row.java  |   3 +-
 .../org/apache/beam/sdk/values/RowWithGetters.java |   3 +
 .../beam/fn/harness/BeamFnDataReadRunner.java      |  58 ++-
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    |  65 ++-
 .../beam/fn/harness/PTransformRunnerFactory.java   |  23 +-
 .../fn/harness/control/ProcessBundleHandler.java   |  50 +--
 .../beam/fn/harness/BeamFnDataReadRunnerTest.java  | 105 +++--
 .../beam/fn/harness/FnApiDoFnRunnerTest.java       | 158 ++++----
 .../PTransformRunnerFactoryTestContext.java        |  20 +-
 .../harness/control/ProcessBundleHandlerTest.java  |   7 -
 sdks/java/io/kafka/build.gradle                    |  12 +-
 .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java |  49 +--
 .../sdk/io/kafka/WatchForKafkaTopicPartitions.java | 185 +++++++++
 .../sdk/io/kafka/WatchKafkaTopicPartitionDoFn.java | 189 ---------
 .../org/apache/beam/sdk/io/kafka/KafkaIOIT.java    | 172 ++++++--
 .../org/apache/beam/sdk/io/kafka/KafkaMocks.java   |  28 ++
 .../io/kafka/WatchForKafkaTopicPartitionsTest.java | 187 +++++++++
 .../io/kafka/WatchKafkaTopicPartitionDoFnTest.java | 449 ---------------------
 sdks/python/apache_beam/coders/stream.pyx          |   8 +-
 .../inference/pytorch_language_modeling.py         |  10 +-
 .../apache_beam/ml/inference/pytorch_inference.py  |   5 +-
 sdks/python/apache_beam/transforms/core.py         |  21 +-
 .../apache_beam/transforms/ptransform_test.py      |  21 +
 website/www/site/content/en/blog/beam-2.40.0.md    |  10 +-
 .../content/en/documentation/programming-guide.md  |  79 +++-
 website/www/site/layouts/case-studies/baseof.html  |   2 +-
 52 files changed, 1118 insertions(+), 1178 deletions(-)
 copy playground/frontend/lib/modules/analytics/{analytics_service.dart => google_analytics_service.dart} (85%)
 create mode 100644 sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/WatchForKafkaTopicPartitions.java
 delete mode 100644 sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/WatchKafkaTopicPartitionDoFn.java
 create mode 100644 sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/WatchForKafkaTopicPartitionsTest.java
 delete mode 100644 sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/WatchKafkaTopicPartitionDoFnTest.java