kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjko...@apache.org
Subject kafka git commit: KAFKA-1914; follow-up to address unit test failure
Date Wed, 18 Feb 2015 22:38:09 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk f5684366e -> 8d72816f4


KAFKA-1914; follow-up to address unit test failure


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8d72816f
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8d72816f
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8d72816f

Branch: refs/heads/trunk
Commit: 8d72816f48d18d61e8ef8b174896c6d177a09a92
Parents: f568436
Author: Joel Koshy <jjkoshy@gmail.com>
Authored: Wed Feb 18 14:38:03 2015 -0800
Committer: Joel Koshy <jjkoshy@gmail.com>
Committed: Wed Feb 18 14:38:03 2015 -0800

----------------------------------------------------------------------
 core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala | 3 ---
 1 file changed, 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/8d72816f/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala b/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala
index 292a042..525c835 100644
--- a/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala
+++ b/core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala
@@ -140,8 +140,5 @@ class SimpleFetchTest extends JUnit3Suite {
       replicaManager.readFromLocalLog(true, true, fetchInfo).get(topicAndPartition).get.info.messageSet.head.message)
     assertEquals("Reading any data can return messages up to the end of the log", messagesToLEO,
       replicaManager.readFromLocalLog(true, false, fetchInfo).get(topicAndPartition).get.info.messageSet.head.message)
-
-    assertEquals("Counts should increment after fetch", initialTopicCount+2, BrokerTopicStats.getBrokerTopicStats(topic).totalFetchRequestRate.count());
-    assertEquals("Counts should increment after fetch", initialTopicCount+2, BrokerTopicStats.getBrokerAllTopicsStats().totalFetchRequestRate.count());
   }
 }


Mime
View raw message