Skip to content

[pull] master from apache:master - #611

Merged
pull[bot] merged 6 commits into
section9-lab:masterfrom
apache:master
Aug 17, 2026
Merged

[pull] master from apache:master#611
pull[bot] merged 6 commits into
section9-lab:masterfrom
apache:master

Conversation

@pull

@pull pull Bot commented Aug 17, 2026

Copy link
Copy Markdown

See Commits and Changes for more details.


Created by pull[bot] (v2.0.0-alpha.4)

Can you help keep this open source service alive? 💖 Please sponsor : )

dependabot Bot and others added 6 commits August 17, 2026 12:55
Bumps [github.com/aws/aws-sdk-go-v2/service/s3](https://github.com/aws/aws-sdk-go-v2) from 1.107.0 to 1.107.1.
- [Release notes](https://github.com/aws/aws-sdk-go-v2/releases)
- [Commits](aws/aws-sdk-go-v2@service/s3/v1.107.0...service/s3/v1.107.1)

---
updated-dependencies:
- dependency-name: github.com/aws/aws-sdk-go-v2/service/s3
  dependency-version: 1.107.1
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
* [Python] Refactor MatchContinuously onto the Watch transform

Route MatchContinuously through Watch when deduplication is enabled. The
polling loop and the set of already-matched file ids now live in the
splittable DoFn restriction, replacing the per-key state DoFns.

* Add a timestamp_cursor option to MatchContinuously

Opt-in timestamp_cursor=True backs deduplication with the Watch
transform's cursor mode, so the restriction holds one timestamp rather
than an id per matched file. The poll stamps each match with its
last-modified time, which is what the cursor dedups on, and the
watermark stays at the poll time.
Configure the native Python Bigtable write client with a Beam user
agent (apache-beam/<version> (GPN:Beam)), matching the Java BigtableIO
behavior and the convention used by gcsio.py and the Datastore
connector.
* update postcommit yaml tests workflow to support new blueprints workflow

* add new delta lake to iceberg blueprint

* post commit trigger

* add test set name to run step

* change name from blueprints to e2e
)

* Feat: implementing active cleanup of orphaned subscriptions for the `taxirides` topic.

* fix: Correct duplicated subscription path in stale_cleaner.py and update stale_cleaner_test.py
@pull pull Bot locked and limited conversation to collaborators Aug 17, 2026
@pull pull Bot added the ⤵️ pull label Aug 17, 2026
@pull
pull Bot merged commit a01a5cf into section9-lab:master Aug 17, 2026
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants