Changes cleanup thread to forceExecute. #38073

Merged

Abacn merged 6 commits intoapache:masterfrom

Apr 10, 2026

Commits on Apr 4, 2026

Changes cleanup thread to forceExecute. Otherwise, we can deadlock if all finalization threads are running.
acrites
committed

Commits on Apr 6, 2026

Changes cacheCommitFinalizers loop to only acquire the lock once and to not queue cleanup thread while holding the lock.
acrites
committed

Commits on Apr 7, 2026

Changes bundle finalizers to run in a dedicated ScheduledExecutorService to simplify logic and prevent it from blocking work item processing. Adds an integration test at StreamingDataflowWorker level.
acrites
committed
Changes thread pool to a single thread and moves scheduling cleanup under the lock to prevent race with adding to commitFinalizationCallbacks.
acrites
committed

Commits on Apr 8, 2026