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