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

Posted to commits@kafka.apache.org by gu...@apache.org on 2020/03/06 23:39:19 UTC

[kafka] branch trunk updated (ca90a84 -> d3c067f)

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

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


    from ca90a84  KAFKA-9668: Iterating over KafkaStreams.getAllMetadata() results in ConcurrentModificationException (#8233)
     add d3c067f  MINOR: Check store directory empty to decide whether throw task corrupted exception with EOS (#8180)

No new revisions were added by this update.

Summary of changes:
 .../streams/errors/TaskCorruptedException.java     |  8 +-
 .../streams/processor/internals/AbstractTask.java  |  2 +-
 .../processor/internals/ActiveTaskCreator.java     |  7 +-
 .../processor/internals/ProcessorStateManager.java | 45 +++++++----
 .../processor/internals/StandbyTaskCreator.java    |  9 ++-
 .../processor/internals/StateDirectory.java        | 16 ++++
 .../processor/internals/StateManagerUtil.java      |  9 ++-
 .../processor/internals/StoreChangelogReader.java  |  2 +-
 .../streams/processor/internals/StreamTask.java    | 74 +++++++++---------
 .../streams/processor/internals/StreamThread.java  |  1 +
 .../kafka/streams/processor/internals/Task.java    |  2 +-
 .../streams/processor/internals/TaskManager.java   | 14 +---
 .../EOSUncleanShutdownIntegrationTest.java         | 11 +--
 .../internals/ProcessorStateManagerTest.java       | 87 ++++++++++++++++------
 .../processor/internals/StandbyTaskTest.java       | 12 ++-
 .../processor/internals/StateDirectoryTest.java    | 45 +++++++++++
 .../processor/internals/StateManagerUtilTest.java  | 16 ++--
 .../processor/internals/StreamTaskTest.java        | 29 ++++++--
 .../StreamThreadStateStoreProviderTest.java        |  7 +-
 .../apache/kafka/streams/TopologyTestDriver.java   |  7 +-
 20 files changed, 281 insertions(+), 122 deletions(-)