private void logDataLossMsg(HCatFieldSchema fieldSchema, Object pigOjb, String msg) {
      String key = getColumnTypeKey(fieldSchema);
      if(!msgCount.containsKey(key)) {
        msgCount.put(key, 0);
        LOG.warn(msg + " " + "Will write NULL instead.  Only 1 such message per type/column is emitted.");
      }
      msgCount.put(key, msgCount.get(key) + 1);
    }
todo: when job is complete, should print the msgCount table to log
hcatalog/hcatalog-pig-adapter/src/main/java/org/apache/hive/hcatalog/pig/HCatBaseStorer.java