if(pipelineData.getFatalError() != null)
throw pipelineData.getFatalError();
for(ByteArray key: keys) {
List<Node> allNodesList = routingStrategy.routeRequest(key.get());
assertEquals(cluster.getNumberOfNodes(), allNodesList.size());
List<Node> extraNodes = pipelineData.getKeyToExtraNodesMap().get(key);
assertEquals(cluster.getNumberOfNodes() - preferred, extraNodes.size());