kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (ca90a84 -> d3c067f)
Date Fri, 06 Mar 2020 23:39:19 GMT
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(-)


Mime
View raw message