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 2020/08/10 22:33:22 UTC

[kafka] branch trunk updated (c8bccdd -> 3e6dcb1)

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 c8bccdd  MINOR: Fix state transition diagram for stream threads (#9153)
     add 3e6dcb1  MINOR: Improve checks for CogroupedStreamAggregateBuilder (#9141)

No new revisions were added by this update.

Summary of changes:
 .../kstream/internals/CogroupedKStreamImpl.java    |   5 +-
 .../internals/CogroupedStreamAggregateBuilder.java | 170 +++++++++++++--------
 .../SessionWindowedCogroupedKStreamImpl.java       |   4 +-
 .../TimeWindowedCogroupedKStreamImpl.java          |  22 ++-
 4 files changed, 121 insertions(+), 80 deletions(-)