Method multiPutWithOneBadRpcInBatch

test/TestIntegration.java:535–570

Send a bunch of edits with one that references a non-existent family.

()

  /** Send a bunch of edits with one that references a non-existent family. */
  @Test
  public void multiPutWithOneBadRpcInBatch() throws Exception {
    client.setFlushInterval(FAST_FLUSH);
    final PutRequest put1 = new PutRequest(table, "mk1", family, "m1", "mpb1");
    // The following edit is destined to a non-existent family.
    final PutRequest put2 = new PutRequest(table, "mk2", family + family,
                                           "m2", "mpb2");
    final PutRequest put3 = new PutRequest(table, "mk3", family, "m3", "mpb3");
    try {
      final ArrayList<Deferred<Object>> ds = new ArrayList<Deferred<Object>>(3);
      ds.add(client.put(put1));
      ds.add(client.put(put2));
      ds.add(client.put(put3));
      Deferred.groupInOrder(ds).join();
    } catch (DeferredGroupException e) {
      final ArrayList<Object> results = e.results();
      final Object res2 = results.get(1);
      if (!(res2 instanceof NoSuchColumnFamilyException)) {
        throw new AssertionError("res2 wasn't a NoSuchColumnFamilyException: "
                                 + res2);
      }
      assertEquals(put2, ((NoSuchColumnFamilyException) res2).getFailedRpc());
      final GetRequest get1 = new GetRequest(table, "mk1", family, "m1");
      ArrayList<KeyValue> kvs = client.get(get1).join();
      assertSizeIs(1, kvs);
      assertEq("mpb1", kvs.get(0).value());
      final GetRequest get2 = new GetRequest(table, "mk2", family, "m2");
      assertSizeIs(0, client.get(get2).join());
      final GetRequest get3 = new GetRequest(table, "mk3", family, "m3");
      kvs = client.get(get3).join();
      assertSizeIs(1, kvs);
      assertEq("mpb3", kvs.get(0).value());
      return;
    }
    throw new AssertionError("Should never be here");
  }

  /** Lots of buffered counter increments from multiple threads. */
  @Test