You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2015/02/27 00:03:35 UTC
kafka git commit: kafka-1881;
transient unit test failure in testDeleteTopicWithCleaner due to OOME;
patched by Ewen Cheslack-Postava; reviewed by Jun Rao
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 <me...@ewencp.org>
Authored: Thu Feb 26 15:03:12 2015 -0800
Committer: Jun Rao <ju...@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