You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2025/10/29 04:08:30 UTC
(beam) branch nightly-refs/heads/master updated (0f6b605f9e5 -> b2960c9db3e)
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 0f6b605f9e5 Fix a bug in streaming OrderedWindowElements. (#36642)
add 0c10658e9ba [Dataflow Streaming] Intern encoded tags across keys (#36313)
add 949c87f0e20 Cache IntervalWindow hashCode (#36612)
add ecc840cd1e7 [Java SDK] Fix propagation of metrics set during onTimer processing. (#36576)
add 942de54a14c Adding release-2.69.0-postrelease to protected branches in .asf.yaml
add 00516e97235 Update managed-io.md for release 2.69.0-RC2.
add 3deba11b8a2 Merge pull request #36569 from apache/updates_managed_io_docs_2.69.0_rc2
add bcf41e14aba Add missing py313 ML container requirements file (#36647)
add be7acf5eca2 Update Beam website to release 2.69.0
add be47decb542 Update date
add 37ca7d54090 Update breaking changes
add fdc89112719 Merge pull request #36554 from apache/release-269-website
add 5a8e2dc3996 remove empty file (#36648)
add 5fe0d4c084b Add batch version of OrderedWindowElements in examples (#36621)
add 3432480129c Update website for roadmap and version compatibility (#36602)
add 21dbf592f87 Adds Multimap support to JAVA FnApi (#36218)
add c60b8ae8671 Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#36644)
add b33ab6e2e94 Bump cloud.google.com/go/bigquery from 1.70.0 to 1.71.0 in /sdks (#36500)
add b2960c9db3e fix(website): Use standard method for CSP frame-src exceptions (#36653)
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 1 +
CHANGES.md | 10 +-
.../beam/model/fn_execution/v1/beam_fn_api.proto | 24 +
.../beam/model/pipeline/v1/beam_runner_api.proto | 10 +-
.../util/common/worker/InternedByteString.java | 77 +
.../worker/windmill/state/CachingStateTable.java | 137 +-
.../worker/windmill/state/WindmillBag.java | 21 +-
.../windmill/state/WindmillCombiningState.java | 20 +-
.../worker/windmill/state/WindmillMap.java | 30 +-
.../worker/windmill/state/WindmillMultimap.java | 24 +-
.../worker/windmill/state/WindmillOrderedList.java | 17 +-
.../worker/windmill/state/WindmillStateCache.java | 82 +-
.../windmill/state/WindmillStateTagUtil.java | 10 +-
.../worker/windmill/state/WindmillValue.java | 21 +-
.../windmill/state/WindmillWatermarkHold.java | 30 +-
.../util/common/worker/InternedByteStringTest.java | 68 +
.../windmill/state/WindmillStateCacheTest.java | 232 ++-
.../windmill/state/WindmillStateTagUtilTest.java | 10 +-
sdks/go.mod | 6 +-
sdks/go.sum | 12 +-
.../beam/sdk/fn/stream/PrefetchableIterables.java | 2 +-
.../sdk/transforms/windowing/IntervalWindow.java | 17 +-
.../beam/sdk/util/construction/Environments.java | 1 +
.../org/apache/beam/sdk/transforms/ParDoTest.java | 67 +
.../sdk/util/construction/EnvironmentsTest.java | 3 +
.../fn/harness/control/ProcessBundleHandler.java | 14 +-
.../harness/data/PCollectionConsumerRegistry.java | 79 +-
.../beam/fn/harness/state/FnApiStateAccessor.java | 121 +-
.../beam/fn/harness/state/MultimapUserState.java | 139 +-
.../harness/control/ProcessBundleHandlerTest.java | 149 ++
.../fn/harness/state/MultimapUserStateTest.java | 129 ++
.../cookbook/ordered_window_elements/batch.py | 522 +++++++
.../cookbook/ordered_window_elements/batch_test.py | 333 ++++
.../{ => ml}/py313/base_image_requirements.txt | 0
website/www/site/config.toml | 2 +-
website/www/site/content/en/blog/beam-2.69.0.md | 86 +
.../en/documentation/dsls/sql/calcite/overview.md | 27 +
.../dsls/sql/calcite/scalar-functions.md | 9 +-
.../en/documentation/dsls/sql/zetasql/overview.md | 2 +-
.../site/content/en/documentation/io/managed-io.md | 1635 +++++++++++++++++---
.../www/site/content/en/documentation/sdks/java.md | 29 +
.../content/en/documentation/sdks/java/euphoria.md | 2 +
.../site/content/en/documentation/sdks/python.md | 51 +-
.../www/site/content/en/get-started/downloads.md | 18 +-
website/www/site/content/en/roadmap/_index.md | 19 +-
.../www/site/content/en/security/CVE-2020-1929.md | 16 -
website/www/site/static/.htaccess | 4 +-
47 files changed, 3650 insertions(+), 668 deletions(-)
create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/InternedByteString.java
create mode 100644 runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/util/common/worker/InternedByteStringTest.java
create mode 100644 sdks/python/apache_beam/examples/cookbook/ordered_window_elements/batch.py
create mode 100644 sdks/python/apache_beam/examples/cookbook/ordered_window_elements/batch_test.py
copy sdks/python/container/{ => ml}/py313/base_image_requirements.txt (100%)
create mode 100644 website/www/site/content/en/blog/beam-2.69.0.md
delete mode 100644 website/www/site/content/en/security/CVE-2020-1929.md