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

catch error

This commit is contained in:
Dhruv Parthasarathy 2013-07-09 17:17:21 -07:00
parent 9f7284c801
commit ba484fca5c
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
examples/src/main/java/druid/examples/webStream/InputSupplierUpdateStream.java
View File

@ -21,7 +21,6 @@ package druid.examples.webStream;
import com.fasterxml.jackson.core.type.TypeReference; import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.common.base.Throwables;
import com.google.common.io.InputSupplier; import com.google.common.io.InputSupplier;
import com.metamx.druid.jackson.DefaultObjectMapper; import com.metamx.druid.jackson.DefaultObjectMapper;
import com.metamx.emitter.EmittingLogger; import com.metamx.emitter.EmittingLogger;
@ -65,14 +64,14 @@ public class InputSupplierUpdateStream implements UpdateStream
queue.offer(map, queueWaitTime, TimeUnit.SECONDS); queue.offer(map, queueWaitTime, TimeUnit.SECONDS);
log.debug("Successfully added to queue"); log.debug("Successfully added to queue");
} else { } else {
log.error("missing timestamp"); log.info("missing timestamp");
} }
} }
} }
} }
catch (Exception e) { catch (Exception e) {
throw Throwables.propagate(e); log.info(e,e.getMessage());
} }
} }
} }