Fix batchlog replay compatibility tests patch by Aleksey Yeschenko; reviewed by Jeff Jirsa for CASSANDRA-13842
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/5893020f Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/5893020f Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/5893020f Branch: refs/heads/master Commit: 5893020fd9f2ca783be13a5a0974504632529440 Parents: 9269038 Author: Aleksey Yeschenko <alek...@yeschenko.com> Authored: Thu Sep 7 17:31:35 2017 +0100 Committer: Aleksey Yeschenko <alek...@yeschenko.com> Committed: Thu Sep 7 17:48:10 2017 +0100 ---------------------------------------------------------------------- batch_test.py | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/5893020f/batch_test.py ---------------------------------------------------------------------- diff --git a/batch_test.py b/batch_test.py index 5c25c46..f8b9881 100644 --- a/batch_test.py +++ b/batch_test.py @@ -383,6 +383,13 @@ class TestBatch(Tester): """ session.execute(query) + # batchlog replay skips over all entries that are younger than + # 2 * write_request_timeout_in_ms ms: 1x timeout for all mutations to be written, + # and another 1x timeout for batch remove mutation to be received. + delay = 2 * coordinator.get_conf_option('write_request_timeout_in_ms') / 1000.0 + 1 + debug('Sleeping for {}s for the batches to not be skipped'.format(delay)) + time.sleep(delay) + total_batches_replayed = 0 blm = make_mbean('db', type='BatchlogManager') --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org