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 2020/10/08 02:09:34 UTC
[kafka] branch trunk updated (250c71b -> 8d4bbf2)

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 250c71b  KAFKA-10564: only process non-empty task directories when internally cleaning obsolete state stores (#9373)
     add 8d4bbf2  MINOR: trivial cleanups, javadoc errors, omitted StateStore tests, etc. (#8130)

No new revisions were added by this update.

Summary of changes:
 checkstyle/import-control.xml                      |  1 -
 .../apache/kafka/connect/sink/SinkTaskContext.java |  2 +-
 .../kafka/connect/source/SourceTaskContext.java    |  2 +-
 core/src/main/scala/kafka/log/Log.scala            |  2 +-
 .../internals/ProcessorRecordContext.java          |  1 -
 .../org/apache/kafka/streams/state/Stores.java     |  6 +++-
 .../state/internals/KeyValueStoreBuilder.java      |  3 +-
 .../internals/MeteredTimestampedWindowStore.java   |  3 +-
 .../state/internals/SessionStoreBuilder.java       |  3 +-
 .../internals/TimestampedKeyValueStoreBuilder.java |  3 +-
 .../internals/TimestampedWindowStoreBuilder.java   |  3 +-
 .../state/internals/WindowStoreBuilder.java        |  4 +++
 .../integration/AbstractJoinIntegrationTest.java   |  2 +-
 .../integration/SuppressionIntegrationTest.java    |  1 -
 .../kstream/internals/SuppressScenarioTest.java    |  2 +-
 .../TimestampedKeyValueStoreMaterializerTest.java  |  1 +
 .../internals/GlobalStateStoreProviderTest.java    | 40 ++++++++++++++++++++++
 .../state/internals/KeyValueStoreBuilderTest.java  | 17 +++++++--
 .../state/internals/SessionStoreBuilderTest.java   | 23 ++++++++++---
 .../StreamThreadStateStoreProviderTest.java        | 27 +++++++++++++++
 .../TimestampedKeyValueStoreBuilderTest.java       | 11 +++++-
 .../TimestampedWindowStoreBuilderTest.java         | 21 ++++++++++++
 .../state/internals/WindowStoreBuilderTest.java    | 23 +++++++++++++
 .../kafka/trogdor/coordinator/TaskManager.java     |  4 +--
 .../kafka/trogdor/workload/ProduceBenchWorker.java |  2 +-
 25 files changed, 182 insertions(+), 25 deletions(-)