svn commit: r1730803 - in /nutch/trunk: CHANGES.txt src/java/org/apache/nutch/fetcher/Fetcher.java

[markus]

Author: markus
Date: Wed Feb 17 09:55:27 2016
New Revision: 1730803

URL: http://svn.apache.org/viewvc?rev=1730803&view=rev
Log:
NUTCH-2224 Average bytes/second calculated incorrectly in fetcher

Modified:
    nutch/trunk/CHANGES.txt
    nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java

Modified: nutch/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/nutch/trunk/CHANGES.txt?rev=1730803&r1=1730802&r2=1730803&view=diff
==============================================================================
--- nutch/trunk/CHANGES.txt (original)
+++ nutch/trunk/CHANGES.txt Wed Feb 17 09:55:27 2016
@@ -1,5 +1,7 @@
 Nutch Change Log
 
+* NUTCH-2224 Average bytes/second calculated incorrectly in fetcher (Tien 
Nguyen Manh via markus)
+
 * NUTCH-2225 Parsed time calculated incorrectly (Tien Nguyen Manh via markus)
 
 * NUTCH-961 Expose Tika's Boilerpipe support (Gabriele Kahlout, Vincent Slot, 
markus)

Modified: nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java
URL: 
http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java?rev=1730803&r1=1730802&r2=1730803&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java Wed Feb 17 
09:55:27 2016
@@ -138,7 +138,7 @@ public class Fetcher extends NutchTool i
     Long elapsed = new Long((System.currentTimeMillis() - start) / 1000);
 
     float avgPagesSec = (float) pages.get() / elapsed.floatValue();
-    long avgBytesSec = (bytes.get() / 125l) / elapsed.longValue();
+    long avgBytesSec = (bytes.get() / 128l) / elapsed.longValue();
 
     status.append(activeThreads).append(" threads (").append(spinWaiting.get())
         .append(" waiting), ");
@@ -148,7 +148,7 @@ public class Fetcher extends NutchTool i
     status.append(String.format("%.2f", avgPagesSec)).append(" pages/s (");
     status.append(pagesLastSec).append(" last sec), ");
     status.append(avgBytesSec).append(" kbits/s (")
-        .append((bytesLastSec / 125)).append(" last sec)");
+        .append((bytesLastSec / 128)).append(" last sec)");
 
     reporter.setStatus(status.toString());
   }