kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vvcep...@apache.org
Subject [kafka] branch trunk updated (e099b58 -> 813f92c)
Date Thu, 09 Jul 2020 18:51:16 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from e099b58  KAFKA-10235 Fix flaky transactions_test.py (#8981)
     add 813f92c  KAFKA-10179: Pass correct changelog topic to state serdes (#8902)

No new revisions were added by this update.

Summary of changes:
 .../internals/AbstractProcessorContext.java        |  16 +-
 .../internals/GlobalProcessorContextImpl.java      |  12 +-
 .../internals/GlobalStateManagerImpl.java          |  23 +--
 .../internals/InternalProcessorContext.java        |   1 +
 .../processor/internals/ProcessorContextImpl.java  |  29 ++--
 .../processor/internals/ProcessorContextUtils.java |   6 +
 .../processor/internals/ProcessorStateManager.java |  30 +++-
 .../processor/internals/ProcessorTopology.java     |   4 +-
 .../streams/processor/internals/StateManager.java  |   4 +-
 .../state/internals/MeteredKeyValueStore.java      |   7 +-
 .../state/internals/MeteredSessionStore.java       |  20 ++-
 .../internals/MeteredTimestampedKeyValueStore.java |   7 +-
 .../internals/MeteredTimestampedWindowStore.java   |  10 +-
 .../state/internals/MeteredWindowStore.java        |   7 +-
 .../internals/graph/TableSourceNodeTest.java       |  76 +++++++++
 .../internals/AbstractProcessorContextTest.java    |  12 +-
 .../internals/GlobalProcessorContextImplTest.java  |   2 +-
 .../internals/InternalTopologyBuilderTest.java     |  20 +++
 .../internals/ProcessorContextImplTest.java        |  24 ++-
 .../internals/ProcessorStateManagerTest.java       |  49 ++++++
 .../processor/internals/StateManagerStub.java      |   4 +
 .../internals/GlobalStateStoreProviderTest.java    |  13 +-
 .../state/internals/MeteredKeyValueStoreTest.java  | 102 +++++++++---
 .../state/internals/MeteredSessionStoreTest.java   | 181 ++++++++++++++-------
 .../MeteredTimestampedKeyValueStoreTest.java       | 128 ++++++++++-----
 .../MeteredTimestampedWindowStoreTest.java         |  76 ++++++++-
 .../state/internals/MeteredWindowStoreTest.java    |  64 +++++++-
 .../apache/kafka/test/GlobalStateManagerStub.java  |   5 +
 .../kafka/test/InternalMockProcessorContext.java   |  18 +-
 .../kafka/test/MockInternalProcessorContext.java   |   5 +
 .../apache/kafka/test/NoOpProcessorContext.java    |  16 +-
 31 files changed, 767 insertions(+), 204 deletions(-)
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNodeTest.java


Mime
View raw message