hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jerry...@apache.org
Subject hbase git commit: HBASE-14228 Close BufferedMutator and connection in MultiTableOutputFormat
Date Tue, 18 Aug 2015 20:44:49 GMT
Repository: hbase
Updated Branches:
  refs/heads/master 68113abec -> 3fa86a98a


HBASE-14228 Close BufferedMutator and connection in MultiTableOutputFormat


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/3fa86a98
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/3fa86a98
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/3fa86a98

Branch: refs/heads/master
Commit: 3fa86a98a0897d091cc5b5318227698e46eff495
Parents: 68113ab
Author: Jerry He <jerryjch@apache.org>
Authored: Tue Aug 18 13:44:41 2015 -0700
Committer: Jerry He <jerryjch@apache.org>
Committed: Tue Aug 18 13:44:41 2015 -0700

----------------------------------------------------------------------
 .../apache/hadoop/hbase/mapreduce/MultiTableOutputFormat.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/3fa86a98/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultiTableOutputFormat.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultiTableOutputFormat.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultiTableOutputFormat.java
index c765c99..7feb7a9 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultiTableOutputFormat.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultiTableOutputFormat.java
@@ -119,9 +119,9 @@ public class MultiTableOutputFormat extends OutputFormat<ImmutableBytesWritable,
     @Override
     public void close(TaskAttemptContext context) throws IOException {
       for (BufferedMutator mutator : mutatorMap.values()) {
-        mutator.flush();
+        mutator.close();
       }
-      if(connection != null){
+      if (connection != null) {
         connection.close();
       }
     }


Mime
View raw message