Permalink
Browse files

CBQE-0 :: fix vbucket map failures

Change-Id: I5e455088e9cb577e6a98002103763ce50ec59e2d
Reviewed-on: http://review.couchbase.org/39448
Reviewed-by: Thuan Nguyen <soccon@gmail.com>
Reviewed-by: Andrei Baranouski <andrei.baranouski@gmail.com>
Reviewed-by: Parag Agarwal <agarwal.parag@gmail.com>
Tested-by: Parag Agarwal <agarwal.parag@gmail.com>
  • Loading branch information...
1 parent f17d3c2 commit 9e477d64cce5abd59ada96ecac8dc1f57628de22 Parag Agarwal committed with paragagarwal Jul 16, 2014
Showing with 3 additions and 3 deletions.
  1. +3 −3 pytests/rebalance/rebalancein.py
@@ -171,16 +171,16 @@ def incremental_rebalance_in_with_ops(self):
# only one type of ops can be passed
if("update" in self.doc_ops):
# 1/2th of data will be updated in each iteration
- tasks += self._async_load_all_buckets(self.master, self.gen_update, "update", 0)
+ tasks += self._async_load_all_buckets(self.master, self.gen_update, "update", 0, batch_size=20000, pause_secs=5, timeout_secs=180)
elif("create" in self.doc_ops):
# 1/2th of initial data will be added in each iteration
gen_create = BlobGenerator('mike', 'mike-', self.value_size, start=self.num_items * (1 + i) / 2.0 , end=self.num_items * (1 + i / 2.0))
- tasks += self._async_load_all_buckets(self.master, gen_create, "create", 0)
+ tasks += self._async_load_all_buckets(self.master, gen_create, "create", 0, batch_size=20000, pause_secs=5, timeout_secs=180)
elif("delete" in self.doc_ops):
# 1/(num_servers) of initial data will be removed after each iteration
# at the end we should get empty base( or couple items)
gen_delete = BlobGenerator('mike', 'mike-', self.value_size, start=int(self.num_items * (1 - i / (self.num_servers - 1.0))) + 1, end=int(self.num_items * (1 - (i - 1) / (self.num_servers - 1.0))))
- tasks += self._async_load_all_buckets(self.master, gen_delete, "delete", 0)
+ tasks += self._async_load_all_buckets(self.master, gen_delete, "delete", 0, batch_size=20000, pause_secs=5, timeout_secs=180)
for task in tasks:
task.result()
self.verify_cluster_stats(self.servers[:i + 2])

0 comments on commit 9e477d6

Please sign in to comment.