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

Posted to commits@kafka.apache.org by vv...@apache.org on 2019/12/04 01:14:16 UTC

[kafka] branch trunk updated (5cddf98 -> 18c13d3)

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

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


    from 5cddf98  KAFKA-9203: Revert "MINOR: Remove workarounds for lz4-java bug affecting byte buffers (#6679)" (#7769)
     add 18c13d3  KAFKA-9231: Streams Threads may die from recoverable errors with EOS enabled (#7748)

No new revisions were added by this update.

Summary of changes:
 .../streams/processor/internals/AbstractTask.java  |   9 +-
 .../processor/internals/AssignedStreamsTasks.java  |   2 +-
 .../streams/processor/internals/AssignedTasks.java |   6 +-
 .../processor/internals/GlobalStateUpdateTask.java |   3 +
 .../processor/internals/RecordCollectorImpl.java   |  24 ++-
 .../internals/RecoverableClientException.java      |  28 +--
 .../streams/processor/internals/StandbyTask.java   |   3 +
 .../streams/processor/internals/StreamTask.java    |  21 +--
 .../streams/state/internals/RocksDBStore.java      |   5 +-
 .../internals/AssignedStreamsTasksTest.java        |  38 +++-
 .../processor/internals/RecordCollectorTest.java   |  21 +++
 .../processor/internals/StreamTaskTest.java        | 197 ++++++++++++++++++++-
 .../streams/processor/internals/TaskSuite.java}    |  29 +--
 .../org/apache/kafka/test/MockKeyValueStore.java   |  19 ++
 14 files changed, 340 insertions(+), 65 deletions(-)
 copy clients/src/main/java/org/apache/kafka/common/errors/InterruptException.java => streams/src/main/java/org/apache/kafka/streams/processor/internals/RecoverableClientException.java (55%)
 copy streams/src/{main/java/org/apache/kafka/streams/processor/internals/GlobalStateMaintainer.java => test/java/org/apache/kafka/streams/processor/internals/TaskSuite.java} (61%)