----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/29755/ -----------------------------------------------------------
(Updated Jan. 10, 2015, 1:37 p.m.) Review request for kafka. Bugs: KAFKA-1853 https://issues.apache.org/jira/browse/KAFKA-1853 Repository: kafka Description ------- KAFKA-1853 Fix potential leak of open LogSegment files during deletion of expired LogSegments. Also fixes the issue of leaving FileMessageSet in a invalid state in such cases Diffs ----- core/src/main/scala/kafka/log/FileMessageSet.scala b2652ddbe2f857028d5980e29a008b2c614694a3 core/src/main/scala/kafka/log/Log.scala 024506cd00556a0037c0b3b6b603da32968b69ab Diff: https://reviews.apache.org/r/29755/diff/ Testing (updated) ------- Have run the existing tests in LogManagerTest (which includes a test for cleaning of expired LogSegments) and those have passed with this change. I did give a thought of trying to replicate a failed rename scenario and then to ensure that we don't leak resources anymore, but that's not straightforward to do in the tests, so haven't added any new tests. Thanks, Jaikiran Pai