You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "vcrfxia (via GitHub)" <gi...@apache.org> on 2023/03/28 23:18:40 UTC
[GitHub] [kafka] vcrfxia opened a new pull request, #13470: KAFKA-14864: Close iterator in KStream windowed aggregation emit on window close
vcrfxia opened a new pull request, #13470:
URL: https://github.com/apache/kafka/pull/13470
As described in https://issues.apache.org/jira/browse/KAFKA-14864, there is currently a memory leak in KStream windowed aggregations when using the ON_WINDOW_CLOSE emit strategy, due to an iterator not being properly cleaned up. This PR fixes the bug, and also updates one other location where a windowed iterator was being created and not closed either.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
--
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-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] mjsax merged pull request #13470: KAFKA-14864: Close iterator in KStream windowed aggregation emit on window close
Posted by "mjsax (via GitHub)" <gi...@apache.org>.
mjsax merged PR #13470:
URL: https://github.com/apache/kafka/pull/13470
--
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-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] mjsax commented on pull request #13470: KAFKA-14864: Close iterator in KStream windowed aggregation emit on window close
Posted by "mjsax (via GitHub)" <gi...@apache.org>.
mjsax commented on PR #13470:
URL: https://github.com/apache/kafka/pull/13470#issuecomment-1489686431
> Execution failed for task ':core:compileTestScala'
Not sure what happened -- re-triggered Jenkins.
--
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-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [kafka] mjsax commented on pull request #13470: KAFKA-14864: Close iterator in KStream windowed aggregation emit on window close
Posted by "mjsax (via GitHub)" <gi...@apache.org>.
mjsax commented on PR #13470:
URL: https://github.com/apache/kafka/pull/13470#issuecomment-1495353048
Thx. Merged to `trunk` and cherry-picked to `3.4` and `3.3` branches.
--
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-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org