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

log.info changed to log.debug

This commit is contained in:
Dhruv Parthasarathy 2013-06-27 19:09:35 -07:00
parent c15f18c343
commit 6f6bf1996c
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
examples/src/main/java/druid/examples/webStream/UpdateStream.java
View File

@ -69,7 +69,7 @@ public class UpdateStream implements Runnable
if (isValid(line)) {
HashMap<String, Object> map = mapper.readValue(line, typeRef);
queue.offer(map, queueWaitTime, TimeUnit.SECONDS);
log.info("Successfully added to queue");
log.debug("Successfully added to queue");
}
}
}

7
examples/src/main/java/druid/examples/webStream/WebFirehoseFactory.java
View File

@ -114,11 +114,10 @@ public class WebFirehoseFactory implements FirehoseFactory
{
Map<String, Object> renamedMap = Maps.newHashMap();
for (int iter = 0; iter < dimensions.size(); iter++) {
if (update.get(dimensions.get(iter)) == null) {
update.put(dimensions.get(iter), null);
if (update.get(dimensions.get(iter)) != null) {
Object obj = update.get(dimensions.get(iter));
renamedMap.put(renamedDimensions.get(iter), obj);
}
Object obj = update.get(dimensions.get(iter));
renamedMap.put(renamedDimensions.get(iter), obj);
}
if (renamedMap.get(timeDimension) == null) {
renamedMap.put(timeDimension, System.currentTimeMillis());