@Test
  public void testConcurrentTransactionBatchCommits() throws Exception {
    List<WriterThd> writers = new ArrayList<WriterThd>(3);
    writers.add(new WriterThd("1,Matrix"));
    writers.add(new WriterThd("2,Gandhi"));
    writers.add(new WriterThd("3,Silence"));

    for (WriterThd w : writers) {
      w.start();
    }
    for (WriterThd w : writers) {
      w.join();
    }
    for (WriterThd w : writers) {
      if (w.error != null) {
        Assert.assertFalse("Writer thread" + w.getName() + " died: " + w.error.getMessage() +
          " See log file for stack trace", true);
      }
    }
  }
check that transactions that have not heartbeated and timedout get properly aborted

@throws Exception
streaming/src/test/org/apache/hive/streaming/TestStreaming.java