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

Posted to commits@kafka.apache.org by jg...@apache.org on 2022/10/13 20:27:32 UTC

[kafka] branch trunk updated (dac81161dbf -> 484f85ff53b)

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

jgus pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from dac81161dbf MINOR; Introduce ImageWriter and ImageWriterOptions (#12715)
     add 484f85ff53b HOTFIX: Revert "KAFKA-12960: Enforcing strict retention time for WindowStore and Sess… (#11211)" (#12745)

No new revisions were added by this update.

Summary of changes:
 ...stractDualSchemaRocksDBSegmentedBytesStore.java |  47 +----
 .../AbstractRocksDBSegmentedBytesStore.java        |  75 ++------
 ...tractRocksDBTimeOrderedSegmentedBytesStore.java |  70 +++-----
 .../internals/RocksDBSegmentedBytesStore.java      |   2 +-
 .../RocksDBTimestampedSegmentedBytesStore.java     |   2 +-
 .../TimeWindowedKStreamIntegrationTest.java        |  66 +++----
 .../KStreamSlidingWindowAggregateTest.java         |  18 +-
 .../internals/KStreamWindowAggregateTest.java      |  61 +++----
 .../internals/SessionWindowedKStreamImplTest.java  |  63 ++-----
 .../internals/TimeWindowedKStreamImplTest.java     | 121 ++++---------
 ...ctDualSchemaRocksDBSegmentedBytesStoreTest.java | 190 ++++++++-------------
 .../AbstractRocksDBSegmentedBytesStoreTest.java    | 163 +++++++++---------
 .../internals/AbstractWindowBytesStoreTest.java    |   4 +-
 .../CachingPersistentWindowStoreTest.java          |   3 +-
 .../state/internals/MeteredSessionStoreTest.java   |  49 ------
 .../MeteredTimestampedWindowStoreTest.java         |   1 -
 .../state/internals/MeteredWindowStoreTest.java    |  14 --
 .../state/internals/RocksDBSessionStoreTest.java   |  93 ----------
 .../state/internals/RocksDBWindowStoreTest.java    | 143 ++++------------
 19 files changed, 350 insertions(+), 835 deletions(-)