Repository: kafka Updated Branches: refs/heads/trunk b8904e961 -> ef252dea7
kafka-1881; transient unit test failure in testDeleteTopicWithCleaner due to OOME; patched by Ewen Cheslack-Postava; reviewed by Jun Rao Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ef252dea Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ef252dea Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ef252dea Branch: refs/heads/trunk Commit: ef252dea704192a8055367d22e45f673f5b06e94 Parents: b8904e9 Author: Ewen Cheslack-Postava <m...@ewencp.org> Authored: Thu Feb 26 15:03:12 2015 -0800 Committer: Jun Rao <jun...@gmail.com> Committed: Thu Feb 26 15:03:12 2015 -0800 ---------------------------------------------------------------------- core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/ef252dea/core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala ---------------------------------------------------------------------- diff --git a/core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala b/core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala index 0cbd726..c8f336a 100644 --- a/core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala +++ b/core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala @@ -230,6 +230,8 @@ class DeleteTopicTest extends JUnit3Suite with ZooKeeperTestHarness { brokerConfigs(0).setProperty("log.cleanup.policy","compact") brokerConfigs(0).setProperty("log.segment.bytes","100") brokerConfigs(0).setProperty("log.segment.delete.delay.ms","1000") + brokerConfigs(0).setProperty("log.cleaner.dedupe.buffer.size","1048577") + val servers = createTestTopicAndCluster(topic,brokerConfigs) // for simplicity, we are validating cleaner offsets on a single broker