You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2014/07/15 16:57:28 UTC
git commit: HBASE-11240 Print hdfs pipeline when hlog's sync is slow
ADDENDUM
Repository: hbase
Updated Branches:
refs/heads/master 96dcd67f5 -> c694ec11d
HBASE-11240 Print hdfs pipeline when hlog's sync is slow ADDENDUM
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/c694ec11
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/c694ec11
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/c694ec11
Branch: refs/heads/master
Commit: c694ec11df3437b2ad24f365e3318dc7e931ddfc
Parents: 96dcd67
Author: stack <st...@apache.org>
Authored: Tue Jul 15 07:57:20 2014 -0700
Committer: stack <st...@apache.org>
Committed: Tue Jul 15 07:57:20 2014 -0700
----------------------------------------------------------------------
.../java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/c694ec11/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java
index 8ff9e03..b816192 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java
@@ -472,7 +472,7 @@ class FSHLog implements HLog, Syncable {
rollWriter();
this.slowSyncNs =
- 1000 * conf.getInt("hbase.regionserver.hlog.slowsync.ms",
+ 1000000 * conf.getInt("hbase.regionserver.hlog.slowsync.ms",
DEFAULT_SLOW_SYNC_TIME_MS);
// handle the reflection necessary to call getNumCurrentReplicas(). TODO: Replace with
// HdfsDataOutputStream#getCurrentBlockReplication() and go without reflection.
@@ -1443,7 +1443,7 @@ class FSHLog implements HLog, Syncable {
if (timeInNanos > this.slowSyncNs) {
String msg =
new StringBuilder().append("Slow sync cost: ")
- .append(timeInNanos / 1000).append(" ms, current pipeline: ")
+ .append(timeInNanos / 1000000).append(" ms, current pipeline: ")
.append(Arrays.toString(getPipeLine())).toString();
Trace.addTimelineAnnotation(msg);
LOG.info(msg);