public HiveStreamingConnection.TxnState getCurrentTransactionState() {
    return state;
  }
A transaction batch opens a single HDFS file and writes multiple transaction to it.  If there is any issue
with the write, we can't continue to write to the same file any as it may be corrupted now (at the tail).
This ensures that a client can't ignore these failures and continue to write.
streaming/src/java/org/apache/hive/streaming/AbstractStreamingTransaction.java