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