Repository: kafka
Updated Branches:
  refs/heads/trunk b8683026e -> b5bc1a1ca


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

…t.test_replica_lags

Author: Grant Henke <granthe...@gmail.com>

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

Closes #1849 from granthenke/replica-verification-fix


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

Branch: refs/heads/trunk
Commit: b5bc1a1caaa8a4ad3b10bfdfa9c2250ef8e09b1d
Parents: b868302
Author: Grant Henke <granthe...@gmail.com>
Authored: Sat Sep 17 22:47:56 2016 +0100
Committer: Ismael Juma <ism...@juma.me.uk>
Committed: Sat Sep 17 22:47:56 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/b5bc1a1c/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)

Reply via email to