diff options
| -rw-r--r-- | storage/src/tests/distributor/mergeoperationtest.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/storage/src/tests/distributor/mergeoperationtest.cpp b/storage/src/tests/distributor/mergeoperationtest.cpp index 1556880d426..672c1d06124 100644 --- a/storage/src/tests/distributor/mergeoperationtest.cpp +++ b/storage/src/tests/distributor/mergeoperationtest.cpp @@ -509,16 +509,16 @@ void MergeOperationTest::merge_operation_is_blocked_by_any_busy_target_node() { void MergeOperationTest::missing_replica_is_included_in_limited_node_list() { setupDistributor(Redundancy(4), NodeCount(4), "distributor:1 storage:4"); getClock().setAbsoluteTimeInSeconds(10); - addNodesToBucketDB(document::BucketId(16, 1), "4=0/0/0/t,1=0/0/0t,2=0/0/0/t"); + addNodesToBucketDB(document::BucketId(16, 1), "1=0/0/0/t,2=0/0/0/t,3=0/0/0/t"); const uint16_t max_merge_size = 2; - MergeOperation op(BucketAndNodes(makeDocumentBucket(document::BucketId(16, 1)), toVector<uint16_t>(0, 1, 2, 4)), max_merge_size); + MergeOperation op(BucketAndNodes(makeDocumentBucket(document::BucketId(16, 1)), toVector<uint16_t>(0, 1, 2, 3)), max_merge_size); op.setIdealStateManager(&getIdealStateManager()); op.start(_sender, framework::MilliSecTime(0)); // Must include missing node 0 and not just 2 existing replicas CPPUNIT_ASSERT_EQUAL( std::string("MergeBucketCommand(BucketId(0x4000000000000001), to time 10000000, " - "cluster state version: 0, nodes: [0, 4], chain: [], " + "cluster state version: 0, nodes: [0, 1], chain: [], " "reasons to start: ) => 0"), _sender.getLastCommand(true)); } |