From ce0caf49aa3fd9cc625027bd66a1b5cdf3600324 Mon Sep 17 00:00:00 2001 From: Micah Warren Date: Tue, 9 Dec 2014 14:31:01 -0600 Subject: [PATCH] Specifying the sink cluster is pretty much required. --- tests/replication2_dirty.erl | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/replication2_dirty.erl b/tests/replication2_dirty.erl index 7da50bd40..a9dddca20 100644 --- a/tests/replication2_dirty.erl +++ b/tests/replication2_dirty.erl @@ -97,7 +97,7 @@ confirm() -> wait_until_coord_has_dirty(LeaderA), lager:info("Starting fullsync"), - repl_util:start_and_wait_until_fullsync_complete(LeaderA), + repl_util:start_and_wait_until_fullsync_complete(LeaderA, "B"), lager:info("Wait for all nodes to show up clean"), wait_until_all_nodes_clean(LeaderA), @@ -120,7 +120,7 @@ confirm() -> wait_until_coord_has_dirty(DirtyB), lager:info("Starting fullsync"), - repl_util:start_and_wait_until_fullsync_complete(LeaderA), + repl_util:start_and_wait_until_fullsync_complete(LeaderA, "B"), lager:info("Wait for all nodes to show up clean"), wait_until_all_nodes_clean(LeaderA), @@ -146,7 +146,7 @@ confirm() -> ResultC = rpc:call(DirtyD, riak_repl_stats, rt_source_errors, []), lager:info("Result = ~p", [ResultC]) end), - repl_util:start_and_wait_until_fullsync_complete(LeaderA), + repl_util:start_and_wait_until_fullsync_complete(LeaderA, "B"), lager:info("Checking to see if C is still clean"), wait_until_node_clean(DirtyC),