You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ct...@apache.org on 2015/07/30 23:51:48 UTC
[14/14] accumulo git commit: ACCUMULO-3949 Formatting
ACCUMULO-3949 Formatting
Apply formatting changes from previous change
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/a9e6d734
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/a9e6d734
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/a9e6d734
Branch: refs/heads/master
Commit: a9e6d7348839517d1bcc8bb4c35e775e126231cb
Parents: da8d8a8
Author: Christopher Tubbs <ct...@apache.org>
Authored: Thu Jul 30 17:42:35 2015 -0400
Committer: Christopher Tubbs <ct...@apache.org>
Committed: Thu Jul 30 17:42:35 2015 -0400
----------------------------------------------------------------------
.../org/apache/accumulo/tserver/tablet/Compactor.java | 11 +++--------
1 file changed, 3 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/a9e6d734/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Compactor.java
----------------------------------------------------------------------
diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Compactor.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Compactor.java
index c1b8105..4c55db9 100644
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Compactor.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Compactor.java
@@ -219,14 +219,9 @@ public class Compactor implements Callable<CompactionStats> {
mfw = null; // set this to null so we do not try to close it again in finally if the close fails
mfwTmp.close(); // if the close fails it will cause the compaction to fail
- log.debug(String.format("Compaction %s %,d read | %,d written | %,6d entries/sec | %,6.3f secs | %,12d bytes | %9.3f byte/sec",
- extent,
- majCStats.getEntriesRead(),
- majCStats.getEntriesWritten(),
- (int) (majCStats.getEntriesRead() / ((t2 - t1) / 1000.0)),
- (t2 - t1) / 1000.0,
- mfwTmp.getLength(),
- mfwTmp.getLength() / ((t2 - t1) / 1000.0)));
+ log.debug(String.format("Compaction %s %,d read | %,d written | %,6d entries/sec | %,6.3f secs | %,12d bytes | %9.3f byte/sec", extent,
+ majCStats.getEntriesRead(), majCStats.getEntriesWritten(), (int) (majCStats.getEntriesRead() / ((t2 - t1) / 1000.0)), (t2 - t1) / 1000.0,
+ mfwTmp.getLength(), mfwTmp.getLength() / ((t2 - t1) / 1000.0)));
majCStats.setFileSize(mfwTmp.getLength());
return majCStats;