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 (065411a -> cb5c731)
Date Wed, 30 Oct 2019 04:20:41 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 065411a  KAFKA-9077: Fix reading of metrics of Streams' SimpleBenchmark (#7610)
     add cb5c731  KAFKA-8972 (2.4 blocker): clear all state for zombie task on TaskMigratedException
(#7608)

No new revisions were added by this update.

Summary of changes:
 .../processor/internals/AssignedStandbyTasks.java  | 10 +--
 .../processor/internals/AssignedStreamsTasks.java  | 96 ++++++++++------------
 .../streams/processor/internals/AssignedTasks.java | 24 ++++--
 .../processor/internals/ChangelogReader.java       |  4 +
 .../processor/internals/StoreChangelogReader.java  | 12 +++
 .../streams/processor/internals/TaskManager.java   |  4 +-
 .../internals/AssignedStreamsTasksTest.java        | 87 ++++++++------------
 .../processor/internals/MockChangelogReader.java   |  5 ++
 .../processor/internals/StreamTaskTest.java        |  2 +-
 .../processor/internals/StreamThreadTest.java      | 12 +--
 10 files changed, 127 insertions(+), 129 deletions(-)


Mime
View raw message