[beam] branch nightly-refs/heads/master updated (d50f1b1790a -> fd854635552)

[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 d50f1b1790a [BEAM-14129] Clean up PubsubLiteIO by removing options that no longer apply (#17169)
     add 3e683606d9a [BEAM-14496] Ensure that precombine is inheriting one of the timestamps output values (#17729)
     add 57354042908 [BEAM-14139] Remove unused Flink 1.11 directory (#17750)
     add 0a6fa95a04d [BEAM-14044] Allow ModelLoader to forward BatchElements args (#17527)
     add 15a5abceaa5  [BEAM-14481] Remove unnecessary context (#17737)
     add a73f32d5a07 [BEAM-9324] Fix incompatibility of direct runner with cython (#17728)
     add 24decb50cf3 [BEAM-14503] Add support for Flink 1.15 (#17739)
     add 83c85a57993 Update Beam website to release 2.39.0 (#17690)
     add 2039b39f96f [BEAM-14509] Add several flags to dataflow runner (#17752)
     add 3130e9c02f8 [BEAM-14494] Fix publish_docker_images.sh (#17756)
     add 59c7a119eb0 [BEAM-14426] Allow skipping of any output when writing an empty PCollection.
     add a2c26cd37d9 Add skip_if_empty attribute to base class to fix test.
     add 4cf268e64c7 Merge pull request #17568 [BEAM-14426] Allow skipping of any output when writing an empty PCollection.
     add f450881f3f7 Bump cloud.google.com/go/storage from 1.22.0 to 1.22.1 in /sdks
     add 45f2dd1e710 Merge pull request #17720: Bump cloud.google.com/go/storage from 1.22.0 to 1.22.1 in /sdks
     add 9bcc1ce0279 Fix 2.38.0 download page.
     add fd854635552 Merge pull request #17759: Fix 2.38.0 download page.

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         |  31 +++-
 gradle.properties                                  |   2 +-
 release/src/main/scripts/publish_docker_images.sh  |   8 +-
 .../runners/flink/streaming/StreamSources.java     |  91 ----------
 .../streaming/ProcessingTimeCallbackCompat.java}   |   6 +-
 .../beam/runners/flink/MiniClusterCompat.java}     |  16 +-
 runners/flink/{1.14 => 1.15}/build.gradle          |   8 +-
 .../job-server-container/build.gradle              |   0
 .../flink/{1.12 => 1.15}/job-server/build.gradle   |   2 +-
 .../streaming/ProcessingTimeCallbackCompat.java}   |   6 +-
 .../beam/runners/flink/MiniClusterCompat.java}     |  17 +-
 runners/flink/flink_runner.gradle                  |  44 +++--
 .../flink/FlinkStreamingTransformTranslators.java  |   4 +-
 .../wrappers/streaming/DoFnOperator.java           |   3 +-
 .../streaming/io/UnboundedSourceWrapper.java       |   4 +-
 .../flink/FlinkRequiresStableInputTest.java        |   2 +-
 .../beam/runners/flink/FlinkSavepointTest.java     |   2 +-
 sdks/go.mod                                        |   4 +-
 sdks/go.sum                                        |   7 +-
 sdks/go/pkg/beam/runners/dataflow/dataflow.go      | 112 ++++++++-----
 sdks/go/pkg/beam/runners/dataflow/dataflow_test.go |  39 ++++-
 .../pkg/beam/runners/dataflow/dataflowlib/job.go   |  21 ++-
 .../main/java/org/apache/beam/sdk/io/TextIO.java   |  14 ++
 .../java/org/apache/beam/sdk/io/WriteFiles.java    |  17 ++
 .../org/apache/beam/sdk/io/TextIOWriteTest.java    |  38 ++++-
 .../beam/fn/harness/PrecombineGroupingTable.java   |  26 ++-
 .../fn/harness/PrecombineGroupingTableTest.java    |  28 ++++
 sdks/python/apache_beam/io/filebasedsink.py        |   4 +-
 sdks/python/apache_beam/io/iobase.py               |  14 +-
 sdks/python/apache_beam/io/textio.py               |  14 +-
 sdks/python/apache_beam/io/textio_test.py          |  20 ++-
 sdks/python/apache_beam/ml/inference/base.py       |   7 +-
 sdks/python/apache_beam/ml/inference/base_test.py  |  22 +++
 .../python/apache_beam/options/pipeline_options.py |   2 +-
 .../apache_beam/runners/worker/bundle_processor.py |  25 ++-
 .../apache_beam/runners/worker/operations.py       |  36 ++--
 settings.gradle.kts                                |   4 +
 website/www/site/config.toml                       |   2 +-
 website/www/site/content/en/blog/beam-2.39.0.md    | 185 +++++++++++++++++++++
 .../www/site/content/en/get-started/downloads.md   |  14 +-
 website/www/site/data/authors.yml                  |   3 +
 41 files changed, 650 insertions(+), 254 deletions(-)
 delete mode 100644 runners/flink/1.11/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java
 copy runners/flink/{src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/package-info.java => 1.12/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ProcessingTimeCallbackCompat.java} (85%)
 copy runners/flink/{src/test/java/org/apache/beam/runners/flink/RemoteMiniCluster.java => 1.12/src/test/java/org/apache/beam/runners/flink/MiniClusterCompat.java} (70%)
 copy runners/flink/{1.14 => 1.15}/build.gradle (84%)
 copy runners/flink/{1.12 => 1.15}/job-server-container/build.gradle (100%)
 copy runners/flink/{1.12 => 1.15}/job-server/build.gradle (95%)
 copy runners/flink/{src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/package-info.java => 1.15/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ProcessingTimeCallbackCompat.java} (83%)
 copy runners/flink/{src/test/java/org/apache/beam/runners/flink/RemoteMiniCluster.java => 1.15/src/test/java/org/apache/beam/runners/flink/MiniClusterCompat.java} (68%)
 create mode 100644 website/www/site/content/en/blog/beam-2.39.0.md