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);
