STORM-1079. Fixed compilation erro and Logging.

cheng1234 · Oct 12, 2015 · fc03910 · fc03910
1 parent 9a25ab7
commit fc03910
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseBolt.java b/external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseBolt.java
@@ -78,13 +78,13 @@ public Map<String, Object> getComponentConfiguration() {
             conf = new Config();
         }
 
-        if (conf.containsKey("topology.message.timeout.secs") && tickTupleInterval == 0) {
+        if (conf.containsKey("topology.message.timeout.secs") && flushIntervalSecs == 0) {
             Integer topologyTimeout = Integer.parseInt(conf.get("topology.message.timeout.secs").toString());
             flushIntervalSecs = (int)(Math.floor(topologyTimeout / 2));
-            LOG.debug("Setting flush interval to [" + flushIntervalSecs + "] based on topology.message.timeout.secs");
+            LOG.debug("Setting flush interval to [{}] based on topology.message.timeout.secs", flushIntervalSecs);
         }
 
-        LOG.info("Enabling tick tuple with interval [" + flushIntervalSecs + "]");
+        LOG.info("Enabling tick tuple with interval [{}]", flushIntervalSecs);
         conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, flushIntervalSecs);
         return conf;
     }