diff --git a/examples/src/main/java/druid/examples/webStream/UpdateStream.java b/examples/src/main/java/druid/examples/webStream/UpdateStream.java
index 626bd2f3b19..3cb7e5ef27a 100644
--- a/examples/src/main/java/druid/examples/webStream/UpdateStream.java
+++ b/examples/src/main/java/druid/examples/webStream/UpdateStream.java
@@ -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");
         }
       }
     }
diff --git a/examples/src/main/java/druid/examples/webStream/WebFirehoseFactory.java b/examples/src/main/java/druid/examples/webStream/WebFirehoseFactory.java
index 8cad52403b5..cebf2b7913c 100644
--- a/examples/src/main/java/druid/examples/webStream/WebFirehoseFactory.java
+++ b/examples/src/main/java/druid/examples/webStream/WebFirehoseFactory.java
@@ -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());