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:00 GMT
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 <granthenke@gmail.com>

Reviewers: Ashish Singh <asingh@cloudera.com>, Ismael Juma <ismael@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 <granthenke@gmail.com>
Authored: Sat Sep 17 22:47:56 2016 +0100
Committer: Ismael Juma <ismael@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)


Mime
View raw message