-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/15674/
-----------------------------------------------------------
(Updated Jan. 3, 2014, 8:27 p.m.)
Review request for kafka.
Summary (updated)
-----------------
add unit test for aborting during cleaning
Bugs: KAFKA-1074
https://issues.apache.org/jira/browse/KAFKA-1074
Repository: kafka
Description (updated)
-------
add test for aborting during cleaning
checkpoint recovery points in truncateFullyAndStartAt()
move cleaning states and locks to a separate class
minor fix 2
minor fix
remove unused var and exception
support pause/resume log clean and remove OptimisticLockFailureException
kafka-1074; minor fix3
kafka-1074; minor fix2
kafka-1074; minor fix
kafka-1074; better synchronization with log cleaner
kafka-1074; fix 4
kafka-1074; fix 3
kafka-1074; fix 2
kafka-1074
Diffs (updated)
-----
core/src/main/scala/kafka/cluster/Partition.scala
5c9307d71641ccc6c09a54b69d5aa2b4bc2a4cde
core/src/main/scala/kafka/common/OptimisticLockFailureException.scala
0e69110e71667ad75a460534f4422a7b6ec1cdc6
core/src/main/scala/kafka/common/ThreadShutdownException.scala PRE-CREATION
core/src/main/scala/kafka/log/Log.scala
beda421b558544196379bd9ab7855cea7614e8e3
core/src/main/scala/kafka/log/LogCleaner.scala
ccde2abd99d2204775e4d3e9836aca34eb6747a3
core/src/main/scala/kafka/log/LogManager.scala
81be88aa618ed5614703d45a0556b77c97290085
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
715845b167c44268bd7e4b76dfb69199bfb2fad4
core/src/main/scala/kafka/server/ReplicaManager.scala
242c18d47828b7c5e6b1fc219a0f1199fb1f9512
core/src/test/scala/unit/kafka/admin/AdminTest.scala
52d35a3ccc86a66acb57c1138d4f2fea8f4ca4b0
core/src/test/scala/unit/kafka/log/CleanerTest.scala
5a312bf0803c1df4636e2e64ba83036a4e8e92dd
Diff: https://reviews.apache.org/r/15674/diff/
Testing
-------
Thanks,
Jun Rao
