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(-)