protected String getWatermark(String partition) {
    return partition + " writeIds[" + curBatchMinWriteId + "," + curBatchMaxWriteId + "]";
  }
used to tag error msgs to provided some breadcrumbs
streaming/src/java/org/apache/hive/streaming/AbstractRecordWriter.java