@Override
    public void run() {
      try {
        for (int i = 0; i < 10; i++) {
          conn.beginTransaction();
          conn.write(data.getBytes());
          conn.write(data.getBytes());
          conn.commitTransaction();
        } // while
      } catch (Exception e) {
        throw new RuntimeException(e);
      } finally {
        if (conn != null) {
          try {
            conn.close();
          } catch (Exception e) {
            LOG.error("txnBatch.close() failed: " + e.getMessage(), e);
          }
        }
      }
    }
check that transactions that have not heartbeated and timedout get properly aborted

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