@Test
public void testAddShardReplicaFailures() throws Exception {

    String name = "testAddShardReplicaFailures";
    MemberNode memberNode = MemberNode.builder(memberNodes).akkaConfig("Member1").testName(name)
            .moduleShardsConfig("module-shards-cars-member-1.conf").build();
    ClusterAdminRpcService service = new ClusterAdminRpcService(memberNode.configDataStore(),
            memberNode.operDataStore(), null);
    RpcResult<AddShardReplicaOutput> rpcResult = service.addShardReplica(new AddShardReplicaInputBuilder()
            .setDataStoreType(DataStoreType.Config).build()).get(10, TimeUnit.SECONDS);
    verifyFailedRpcResult(rpcResult);
    rpcResult = service.addShardReplica(new AddShardReplicaInputBuilder().setShardName("cars")
            .build()).get(10, TimeUnit.SECONDS);
    verifyFailedRpcResult(rpcResult);
    rpcResult = service.addShardReplica(new AddShardReplicaInputBuilder().setShardName("people")
            .setDataStoreType(DataStoreType.Config).build()).get(10, TimeUnit.SECONDS);
    verifyFailedRpcResult(rpcResult);
}