diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroGenericRecordReader.java b/ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroGenericRecordReader.java index 8d58d74..566fa30 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroGenericRecordReader.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/avro/AvroGenericRecordReader.java @@ -134,8 +134,11 @@ private Schema getSchema(JobConf job, FileSplit split) throws AvroSerdeException // It's safe to add this to the job since it's not *actually* a mapred job. // Here the global state is confined to just this process. String s = job.get(AvroSerdeUtils.AVRO_SERDE_SCHEMA); - if(s != null) { - LOG.info("Found the avro schema in the job: " + s); + if (s != null) { + LOG.info("Found the Avro schema in the job"); + if(LOG.isDebugEnabled()) { + LOG.debug("Avro schema: " + s); + } return AvroSerdeUtils.getSchemaFor(s); } // No more places to get the schema from. Give up. May have to re-encode later.