Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reduce log spam from Avro decoders. (#4205) 

These objects get constructed semi-frequently (any time a parser is
deserialized) and so info logs are spammy. They'll still appear in
task logs at least once, since they're part of the task definition and
will get logged due to that.
This commit is contained in:
Gian Merlino 2017-04-26 03:29:59 +09:00 committed by Nishant Bangarwa
parent 336089563d
commit 3b92220015
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
extensions-core/avro-extensions/src/main/java/io/druid/data/input/avro/InlineSchemaAvroBytesDecoder.java
View File

@ -61,7 +61,7 @@ public class InlineSchemaAvroBytesDecoder implements AvroBytesDecoder
this.schema = schema; this.schema = schema;
String schemaStr = mapper.writeValueAsString(schema); String schemaStr = mapper.writeValueAsString(schema);
LOGGER.info("Schema string [%s]", schemaStr); LOGGER.debug("Schema string [%s]", schemaStr);
this.schemaObj = new Schema.Parser().parse(schemaStr); this.schemaObj = new Schema.Parser().parse(schemaStr);
this.reader = new GenericDatumReader<>(this.schemaObj); this.reader = new GenericDatumReader<>(this.schemaObj);
} }

2
extensions-core/avro-extensions/src/main/java/io/druid/data/input/avro/InlineSchemasAvroBytesDecoder.java
View File

@ -73,7 +73,7 @@ public class InlineSchemasAvroBytesDecoder implements AvroBytesDecoder
Map<String, Object> schema = e.getValue(); Map<String, Object> schema = e.getValue();
String schemaStr = mapper.writeValueAsString(schema); String schemaStr = mapper.writeValueAsString(schema);
LOGGER.info("Schema string [%s] = [%s]", id, schemaStr); LOGGER.debug("Schema string [%s] = [%s]", id, schemaStr);
schemaObjs.put(id, new Schema.Parser().parse(schemaStr)); schemaObjs.put(id, new Schema.Parser().parse(schemaStr));
} }
} }