This is an automated email from the ASF dual-hosted git repository. kenn pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 1c22136c6e26a6461c1266357706d25ee0fb7c2a Merge: 0aea01394b1 9a5de4f46ce Author: Kenneth Knowles <[email protected]> AuthorDate: Wed Feb 4 11:25:01 2026 -0500 Merge pull request #37009: [Drain] TimerData causedByDrain field .../beam/runners/core/ReduceFnContextFactory.java | 12 +- .../core/SplittableParDoViaKeyedWorkItems.java | 6 +- .../apache/beam/runners/core/TimerInternals.java | 67 ++++++++-- .../runners/core/InMemoryTimerInternalsTest.java | 84 +++++++++++-- .../beam/runners/core/KeyedWorkItemCoderTest.java | 3 +- .../apache/beam/runners/core/ReduceFnTester.java | 9 +- .../beam/runners/core/SimpleDoFnRunnerTest.java | 3 +- .../SimplePushbackSideInputDoFnRunnerTest.java | 6 +- .../beam/runners/core/TimerInternalsTest.java | 86 +++++++++++-- .../core/triggers/TriggerStateMachineTester.java | 12 +- .../runners/direct/DirectTimerInternalsTest.java | 18 ++- ...cycleManagerRemovingTransformEvaluatorTest.java | 3 +- .../beam/runners/direct/EvaluationContextTest.java | 6 +- .../beam/runners/direct/WatermarkManagerTest.java | 137 ++++++++++++++++----- .../dataflow/worker/WindmillTimerInternals.java | 12 +- .../worker/StreamingGroupAlsoByWindowFnsTest.java | 3 +- ...eamingKeyedWorkItemSideInputDoFnRunnerTest.java | 3 +- .../worker/StreamingModeExecutionContextTest.java | 3 +- .../worker/StreamingSideInputFetcherTest.java | 3 +- .../dataflow/worker/UserParDoFnFactoryTest.java | 9 +- .../dataflow/worker/WindmillKeyedWorkItemTest.java | 6 +- .../windmill/state/WindmillTagEncodingV1Test.java | 30 ++++- .../samza/runtime/ClassicBundleManager.java | 3 +- .../samza/runtime/PortableBundleManager.java | 3 +- .../runners/samza/runtime/KeyedTimerDataTest.java | 7 +- .../runtime/SamzaTimerInternalsFactoryTest.java | 84 +++++++++++-- 26 files changed, 501 insertions(+), 117 deletions(-)
