Skip to content

[pull] master from apache:master - #623

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

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

Conversation

@pull

@pull pull Bot commented Aug 21, 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 : )

Amar3tto and others added 5 commits August 21, 2026 10:24
* Implement Vertex AI Model Monitoring v2

* Add streaming integration test

* trigger postcommits

* shadow model_identifier

* Add support for existing streaming schedules with cron jobs, remove mTLS fallback disable

* Plumb through kwargs

* Add backoff for conflict case

* Check for schedule existance

* Cron handling v2
* [Prism] Schedule consumers of a self checkpointing source

Fixes #39446.

An unbounded source SDF that returns a process continuation residual has
that residual re-queued as a pending element carrying the input element's
event time, MinTimestamp for an Impulse rooted source, so the stage's
watermark never advances. updateWatermarks returns no refreshes when the
output watermark does not move, and PersistBundle marked only the
producing stage as changed, so a consumer that was just handed pending
elements was never surfaced to the scheduler. Its elements accumulated
forever. checkForQuiescence cannot catch this, because the source stays
schedulable, so the job live locks instead of failing fast.

PersistBundle now records the consumers that accepted data, and
updateWatermarks hands them to the scheduler on the path where the output
watermark does not advance. Recording is gated on any bundle having
returned a residual, so a pipeline that never self checkpoints keeps its
previous bundle scheduling.

bundleReady additionally lets a stateful stage with no side inputs run on
pending data alone, under the same gate, since
statefulStageKind.buildEventTimeBundle takes data at any watermark and
gates only timers. Its stillSchedulable now requires buildable work, and
a key that supplies nothing no longer consumes the OneKeyPerBundle slot,
is not marked in progress, and does not hold the bundle's minimum
timestamp.

A consumer that reads a side input still waits on the watermark, since
side input readiness is derived from it.

* Publish all JmsIO records after the pipeline starts

The test pre-published part of the records before running the pipeline
to work around the starvation this change fixes. All records are now
published after the pipeline starts, and the duplicate-tolerant
assertion tightens back to an exact count. Also bumps the messaging
postcommit trigger file.

* Apply suggestion from @Abacn

---------

Co-authored-by: Yi Hu <huuyyi@gmail.com>
* Add JmsIO YAML test

* Fix depends

* Add IBM MQ
@pull pull Bot locked and limited conversation to collaborators Aug 21, 2026
@pull pull Bot added the ⤵️ pull label Aug 21, 2026
@pull
pull Bot merged commit 88b3ee7 into section9-lab:master Aug 21, 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.

3 participants