florin-akermann commented on PR #15189: URL: https://github.com/apache/kafka/pull/15189#issuecomment-1986999670
> So I would have expected that some test need an update with either advancing time pro-actively, or by expected certain result later in the test, because windows are closes later? Indeed good point. I think the problem lies with https://github.com/florin-akermann/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java#L247 `outerJoinLeftBreak && outerJoinRightBreak` is always false. Hence, this loop never exits early? I think this behavior has been introduced as part of https://github.com/apache/kafka/pull/14426? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org