You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2020/07/09 18:51:16 UTC
[kafka] branch trunk updated (e099b58 -> 813f92c)
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