kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-4157; Transient system test failure in replica_verification_test.test_replica_lags
Date Sat, 17 Sep 2016 21:48:14 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.0 ea8c1b394 -> ee6e50024


KAFKA-4157; Transient system test failure in replica_verification_test.test_replica_lags

…t.test_replica_lags

Author: Grant Henke <granthenke@gmail.com>

Reviewers: Ashish Singh <asingh@cloudera.com>, Ismael Juma <ismael@juma.me.uk>

Closes #1849 from granthenke/replica-verification-fix

(cherry picked from commit b5bc1a1caaa8a4ad3b10bfdfa9c2250ef8e09b1d)
Signed-off-by: Ismael Juma <ismael@juma.me.uk>


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

Branch: refs/heads/0.10.0
Commit: ee6e50024d8a09960b2b72628c62c6532c09d84d
Parents: ea8c1b3
Author: Grant Henke <granthenke@gmail.com>
Authored: Sat Sep 17 22:47:56 2016 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Sat Sep 17 22:48:05 2016 +0100

----------------------------------------------------------------------
 tests/kafkatest/services/replica_verification_tool.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/ee6e5002/tests/kafkatest/services/replica_verification_tool.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/services/replica_verification_tool.py b/tests/kafkatest/services/replica_verification_tool.py
index 2033242..2f29d16 100644
--- a/tests/kafkatest/services/replica_verification_tool.py
+++ b/tests/kafkatest/services/replica_verification_tool.py
@@ -63,7 +63,7 @@ class ReplicaVerificationTool(KafkaPathResolverMixin, BackgroundThreadService):
             partition:      a partition of the topic
         """
         topic_partition = topic + ',' + str(partition)
-        lag = self.partition_lag[topic_partition]
+        lag = self.partition_lag.get(topic_partition, -1)
         self.logger.debug("Retuning lag for {} as {}".format(topic_partition, lag))
         return lag
 
@@ -84,4 +84,4 @@ class ReplicaVerificationTool(KafkaPathResolverMixin, BackgroundThreadService):
 
     def clean_node(self, node):
         node.account.kill_process("java", clean_shutdown=False, allow_fail=True)
-        node.account.ssh("rm -rf /mnt/replica_verification_tool.log", allow_fail=False)
\ No newline at end of file
+        node.account.ssh("rm -rf /mnt/replica_verification_tool.log", allow_fail=False)


Mime
View raw message