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 aaecfa8f54583ccd227189bd2e8580dcee78f502 Merge: 7df489cb7c6 4a2afe85f9f Author: Kenneth Knowles <[email protected]> AuthorDate: Wed Feb 11 11:23:10 2026 -0500 Merge pull request #37549: Move CausedByDrain to top level, move types .../beam/runners/core/ReduceFnContextFactory.java | 10 +-- .../core/SplittableParDoViaKeyedWorkItems.java | 3 +- .../apache/beam/runners/core/TimerInternals.java | 12 +-- .../runners/core/InMemoryTimerInternalsTest.java | 37 ++++------ .../beam/runners/core/KeyedWorkItemCoderTest.java | 3 +- .../apache/beam/runners/core/ReduceFnTester.java | 5 +- .../beam/runners/core/SimpleDoFnRunnerTest.java | 3 +- .../SimplePushbackSideInputDoFnRunnerTest.java | 5 +- .../beam/runners/core/TimerInternalsTest.java | 59 ++++----------- .../core/triggers/TriggerStateMachineTester.java | 10 +-- .../runners/direct/DirectTimerInternalsTest.java | 13 ++-- ...cycleManagerRemovingTransformEvaluatorTest.java | 3 +- .../beam/runners/direct/EvaluationContextTest.java | 3 +- .../beam/runners/direct/WatermarkManagerTest.java | 85 ++++++++-------------- .../beam/runners/dataflow/BatchViewOverrides.java | 5 +- .../dataflow/worker/UngroupedWindmillReader.java | 7 +- .../dataflow/worker/WindmillKeyedWorkItem.java | 7 +- .../dataflow/worker/WindmillTimerInternals.java | 5 +- .../dataflow/worker/util/ValueInEmptyWindows.java | 5 +- .../worker/StreamingGroupAlsoByWindowFnsTest.java | 3 +- ...eamingKeyedWorkItemSideInputDoFnRunnerTest.java | 3 +- .../worker/StreamingModeExecutionContextTest.java | 3 +- .../worker/StreamingSideInputFetcherTest.java | 3 +- .../dataflow/worker/UserParDoFnFactoryTest.java | 7 +- .../dataflow/worker/WindmillKeyedWorkItemTest.java | 9 ++- .../windmill/state/WindmillTagEncodingV1Test.java | 15 ++-- .../windmill/state/WindmillTagEncodingV2Test.java | 3 +- .../samza/runtime/ClassicBundleManager.java | 3 +- .../samza/runtime/PortableBundleManager.java | 3 +- .../runners/samza/runtime/KeyedTimerDataTest.java | 3 +- .../runtime/SamzaTimerInternalsFactoryTest.java | 25 ++++--- .../apache/beam/runners/spark/util/TimerUtils.java | 5 +- .../org/apache/beam/sdk/values/CausedByDrain.java | 23 ++++++ .../org/apache/beam/sdk/values/OutputBuilder.java | 2 +- .../org/apache/beam/sdk/values/WindowedValue.java | 2 +- .../org/apache/beam/sdk/values/WindowedValues.java | 58 ++++++++------- .../apache/beam/sdk/util/WindowedValueTest.java | 5 +- 37 files changed, 218 insertions(+), 237 deletions(-)
