kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject kafka git commit: kafka-1881; transient unit test failure in testDeleteTopicWithCleaner due to OOME; patched by Ewen Cheslack-Postava; reviewed by Jun Rao
Date Thu, 26 Feb 2015 23:03:35 GMT
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 <junrao@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


Mime
View raw message