kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch 1.1 updated (3797854 -> ee6dda0)
Date Thu, 14 Jun 2018 17:43:02 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from 3797854  KAFKA-6860: Fix NPE in Kafka Streams with EOS enabled (#5187)
     add ee6dda0  KAFKA-7021: checkpoint offsets from committed (#5207)

No new revisions were added by this update.

Summary of changes:
 .../kstream/internals/InternalStreamsBuilder.java  |  1 -
 .../streams/processor/internals/AbstractTask.java  |  4 +-
 .../internals/InternalTopologyBuilder.java         |  8 +-
 .../processor/internals/ProcessorStateManager.java | 30 ++++---
 .../processor/internals/StateDirectory.java        |  2 +-
 .../streams/processor/internals/StreamTask.java    | 13 ++-
 .../streams/processor/internals/StreamThread.java  |  4 +
 .../apache/kafka/streams/StreamsBuilderTest.java   | 21 ++++-
 .../integration/RestoreIntegrationTest.java        | 92 ++++++++++------------
 .../integration/TableTableJoinIntegrationTest.java |  4 +-
 .../internals/InternalStreamsBuilderTest.java      |  2 +-
 .../internals/ProcessorStateManagerTest.java       | 38 ++++-----
 .../processor/internals/StreamThreadTest.java      | 78 ++++++++++++++++++
 13 files changed, 202 insertions(+), 95 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
guozhang@apache.org.

Mime
View raw message