commit c440a9f901a9f29b60f10047cb67e0b1cb188f89
author Eric Yang <eyang@apache.org> Sun Oct 11 13:21:19 2015 -0700
committer Eric Yang <eyang@apache.org> Sun Oct 11 13:21:19 2015 -0700
tree 047952be0cada8d414dd4f4bd835737286779dd4
parent 93a1f75c45f7333dcba2980f5ec9ebbdc64bb9d3

CHUKWA-784. Improve CharFileTailingAdaptorUTF8NewLineEscaped and LocalWriter
                    logic to send proper data chunk. (Eric Yang)

src/main/java/org/apache/hadoop/chukwa/datacollection/writer/localfs/LocalWriter.java

diff --git a/src/main/java/org/apache/hadoop/chukwa/datacollection/writer/localfs/LocalWriter.java b/src/main/java/org/apache/hadoop/chukwa/datacollection/writer/localfs/LocalWriter.java
index 527b4c3..6d4babe 100644
--- a/src/main/java/org/apache/hadoop/chukwa/datacollection/writer/localfs/LocalWriter.java
+++ b/src/main/java/org/apache/hadoop/chukwa/datacollection/writer/localfs/LocalWriter.java
@@ -219,6 +219,9 @@
       long interval = time - lastTs;
       lastTs = time;
 
+      if(interval <= 0) {
+        interval = 1;
+      }
       long dataRate = 1000 * currentDs / interval; // kb/sec
       log.info("stat:datacollection.writer.local.LocalWriter dataSize="
           + currentDs + " dataRate=" + dataRate);