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

Reply via email to