You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@storm.apache.org by ra...@apache.org on 2026/06/18 00:06:15 UTC

(storm) 01/01: Merge pull request #8790 from dpol1/fix/7782

This is an automated email from the ASF dual-hosted git repository.

reiabreu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git

commit 30621226ec1b40f2fdc3fba381a6e4513579820b
Merge: 8f876533f c55a572be
Author: reiabreu <ru...@gmail.com>
AuthorDate: Thu Jun 18 01:06:07 2026 +0100

    Merge pull request #8790 from dpol1/fix/7782
    
    Fix late tuple stream serialization in windowed bolts

 docs/Windowing.md                                  |   9 +-
 .../storm/serialization/SerializationFactory.java  |   2 +
 .../storm/streams/windowing/SlidingWindows.java    |   3 +
 .../storm/streams/windowing/TumblingWindows.java   |   3 +
 .../storm/topology/WindowedBoltExecutor.java       |   8 +-
 .../storm/topology/base/BaseWindowedBolt.java      |   3 +
 .../jvm/org/apache/storm/tuple/DetachedTuple.java  | 262 +++++++++++++++++++++
 .../PersistentWindowedBoltExecutorTest.java        |   6 +-
 .../storm/topology/WindowedBoltExecutorTest.java   |  52 +++-
 .../org/apache/storm/tuple/DetachedTupleTest.java  | 183 ++++++++++++++
 10 files changed, 527 insertions(+), 4 deletions(-)