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

Posted to commits@kafka.apache.org by mj...@apache.org on 2021/04/30 02:50:49 UTC

[kafka] branch trunk updated (9dbf222 -> e454bec)

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

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


    from 9dbf222  MINOR: clean up some remaining locking stuff in StateDirectory (#10608)
     add e454bec  KAFKA-12396: added null check for state stores key (#10548)

No new revisions were added by this update.

Summary of changes:
 .../state/internals/InMemoryKeyValueStore.java     |  3 --
 .../state/internals/MeteredKeyValueStore.java      | 13 ++++-
 .../state/internals/MeteredSessionStore.java       |  6 +++
 .../state/internals/MeteredWindowStore.java        | 10 ++++
 .../streams/state/internals/RocksDBStore.java      |  3 --
 .../state/internals/InMemoryKeyValueStoreTest.java |  6 +++
 .../state/internals/MeteredKeyValueStoreTest.java  | 51 ++++++++++++++++++++
 .../state/internals/MeteredSessionStoreTest.java   | 55 ++++++++++++++++++++++
 .../state/internals/MeteredWindowStoreTest.java    | 36 ++++++++++++++
 9 files changed, 176 insertions(+), 7 deletions(-)