[beam] branch nightly-refs/heads/master updated (cc48828cc83 -> 32efddcf6d7)

[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 cc48828cc83 Merge pull request #22049: Projection Pushdown optimizer on by default
     add f9d7a159448 [BEAM-14187] Fix NPE at initializeForKeyedRead in IsmReaderImpl (#22111)
     add dd813a7f735 Remove unused legacy dataflow translate code (#22019)
     add 2057e42a960 Fixes #21698: Use normal Container snapshots for Go Load Tests (#22102)
     add 51bcf244081 Change default, options, and explanation for issue priority (#22116)
     add b30de9f163c Minor: Bump flake8 to 4.0.1 (#22110)
     add d6b62537065 Add sdk_harness_log_level_overrides option for python sdk (#22077)
     add 830a030cfb2 Do not re-create PlaygroundState (#21950)
     add fa7d1b5dbd8 Merge pull request #21956 from [Playground] Do not re-create PlaygroundState (#21950)
     add 6e6e1153b13  Fix typo in Pytorch Bert Language Modeling (#22114)
     add 32efddcf6d7 Fix #21977: Add Search transform to Go FhirIO (#21979)

No new revisions were added by this update.

Summary of changes:
 .github/ISSUE_TEMPLATE/bug.yml                     |   8 +-
 .github/ISSUE_TEMPLATE/feature.yml                 |   7 +-
 .github/ISSUE_TEMPLATE/task.yml                    |   7 +-
 .test-infra/jenkins/LoadTestsBuilder.groovy        |   2 +
 .../jenkins/job_LoadTests_Combine_Flink_Go.groovy  |  12 +-
 .../jenkins/job_LoadTests_Combine_Go.groovy        |   8 +-
 .../jenkins/job_LoadTests_GBK_Flink_Go.groovy      |  19 +-
 .test-infra/jenkins/job_LoadTests_GBK_Go.groovy    |  16 +-
 .../jenkins/job_LoadTests_ParDo_Flink_Go.groovy    |  13 +-
 .test-infra/jenkins/job_LoadTests_ParDo_Go.groovy  |  10 +-
 .../job_LoadTests_SideInput_Flink_Go.groovy        |   9 +-
 .../jenkins/job_LoadTests_SideInput_Go.groovy      |   6 +-
 .../jenkins/job_LoadTests_coGBK_Flink_Go.groovy    |  13 +-
 .test-infra/jenkins/job_LoadTests_coGBK_Go.groovy  |  10 +-
 .../jenkins/job_Publish_Docker_Snapshots.groovy    |   1 -
 CHANGES.md                                         |   1 +
 .../embedded_page_providers.dart                   |  14 +-
 .../components/playground_page_providers.dart      |  12 +-
 .../runners/dataflow/worker/IsmReaderImpl.java     |   3 +-
 sdks/go/data/fhir_bundles/transaction-success.json |  86 ++++-
 sdks/go/pkg/beam/io/fhirio/common.go               |  85 +++--
 sdks/go/pkg/beam/io/fhirio/execute_bundles.go      |  20 +-
 sdks/go/pkg/beam/io/fhirio/execute_bundles_test.go |  24 +-
 sdks/go/pkg/beam/io/fhirio/read.go                 |   8 +-
 sdks/go/pkg/beam/io/fhirio/read_test.go            |   8 +-
 sdks/go/pkg/beam/io/fhirio/search.go               | 168 ++++++++++
 sdks/go/pkg/beam/io/fhirio/search_test.go          | 106 ++++++
 sdks/go/pkg/beam/io/fhirio/utils_test.go           |  63 +++-
 .../beam/runners/dataflow/dataflowlib/execute.go   |  15 +-
 .../pkg/beam/runners/dataflow/dataflowlib/fixup.go |  25 --
 .../pkg/beam/runners/dataflow/dataflowlib/job.go   |  20 +-
 .../beam/runners/dataflow/dataflowlib/translate.go | 363 ---------------------
 sdks/go/test/integration/io/fhirio/fhirio_test.go  |  48 +++
 sdks/python/apache_beam/dataframe/transforms.py    |   2 +-
 .../inference/pytorch_language_modeling.py         |   2 +-
 .../apache_beam/io/azure/blobstoragefilesystem.py  |   4 +-
 .../apache_beam/io/gcp/bigquery_avro_tools.py      |   4 +-
 .../python/apache_beam/options/pipeline_options.py |  14 +
 .../runners/dataflow/dataflow_runner.py            |   2 +-
 .../apache_beam/runners/direct/test_stream_impl.py |   3 +-
 .../runners/interactive/interactive_beam.py        |   4 +-
 .../runners/interactive/options/capture_control.py |   4 +-
 .../interactive/options/capture_limiters.py        |   4 +-
 .../runners/interactive/recording_manager.py       |  18 +-
 .../apache_beam/runners/interactive/utils.py       |  12 +-
 .../portability/fn_api_runner/watermark_manager.py |   4 +-
 .../apache_beam/runners/worker/bundle_processor.py |   2 +-
 .../apache_beam/runners/worker/sdk_worker_main.py  |  40 ++-
 .../runners/worker/sdk_worker_main_test.py         |  50 +++
 sdks/python/apache_beam/transforms/window.py       |   2 +-
 sdks/python/apache_beam/typehints/decorators.py    |   2 +-
 sdks/python/apache_beam/typehints/schemas.py       |   2 +-
 sdks/python/tox.ini                                |   4 +-
 53 files changed, 754 insertions(+), 635 deletions(-)
 create mode 100644 sdks/go/pkg/beam/io/fhirio/search.go
 create mode 100644 sdks/go/pkg/beam/io/fhirio/search_test.go
 delete mode 100644 sdks/go/pkg/beam/runners/dataflow/dataflowlib/fixup.go
 delete mode 100644 sdks/go/pkg/beam/runners/dataflow/dataflowlib/translate.go