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/19 18:08:40 UTC

[kafka] branch trunk updated (2db67db -> aef6cd6)

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 2db67db  MINOR: Update jdk and maven names in Jenkinsfile (#9453)
     add aef6cd6  KAFKA-9274: Add timeout handling for state restore and StandbyTasks (#9368)

No new revisions were added by this update.

Summary of changes:
 .../streams/processor/internals/AbstractTask.java  |  37 +++-
 .../processor/internals/ChangelogReader.java       |   4 +-
 .../streams/processor/internals/ClientUtils.java   |  12 +-
 .../streams/processor/internals/StandbyTask.java   |  32 +--
 .../processor/internals/StoreChangelogReader.java  |  95 +++++++--
 .../streams/processor/internals/StreamTask.java    |  30 +--
 .../streams/processor/internals/StreamThread.java  |   4 +-
 .../kafka/streams/processor/internals/Task.java    |   5 +-
 .../streams/processor/internals/TaskManager.java   |  24 ++-
 .../processor/internals/MockChangelogReader.java   |   3 +-
 .../processor/internals/StandbyTaskTest.java       |  15 +-
 .../internals/StoreChangelogReaderTest.java        | 230 ++++++++++++++++-----
 .../processor/internals/StreamTaskTest.java        |  16 +-
 .../processor/internals/StreamThreadTest.java      |   4 +-
 .../processor/internals/TaskManagerTest.java       |  98 ++++-----
 15 files changed, 400 insertions(+), 209 deletions(-)