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/02/21 00:15:35 UTC

[kafka] branch trunk updated (0d16c26 -> 3b6573c)

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 0d16c26  HOTFIX: don't try to remove uninitialized changelogs from assignment & don't prematurely mark task closed (#8140)
     add 3b6573c  KAFKA-9481: Graceful handling TaskMigrated and TaskCorrupted (#8058)

No new revisions were added by this update.

Summary of changes:
 .../apache/kafka/common/utils/FixedOrderMap.java   |   6 --
 .../kafka/common/utils/FixedOrderMapTest.java      |  14 ---
 .../streams/errors/TaskCorruptedException.java     |  46 +++++++++
 .../streams/errors/TaskMigratedException.java      |  50 +---------
 .../streams/processor/internals/AbstractTask.java  |  21 ++++
 .../processor/internals/ProcessorStateManager.java |  26 ++++-
 .../processor/internals/RecordCollectorImpl.java   |  10 +-
 .../streams/processor/internals/StandbyTask.java   |  23 ++---
 .../processor/internals/StoreChangelogReader.java  |  33 +++++--
 .../streams/processor/internals/StreamTask.java    | 107 +++++++++++----------
 .../streams/processor/internals/StreamThread.java  |  39 ++++----
 .../kafka/streams/processor/internals/Task.java    |  57 ++++++-----
 .../streams/processor/internals/TaskManager.java   | 102 +++++++++++++-------
 .../processor/internals/StreamTaskTest.java        |  44 ++++++++-
 .../processor/internals/StreamThreadTest.java      |   6 +-
 .../processor/internals/TaskManagerTest.java       |   7 +-
 16 files changed, 359 insertions(+), 232 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/errors/TaskCorruptedException.java