Repository: hbase Updated Branches: refs/heads/master e5f3dd682 -> 72a6a670a
HBASE-12849 LoadIncrementalHFiles should use unmanaged connection in branch-1 Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/72a6a670 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/72a6a670 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/72a6a670 Branch: refs/heads/master Commit: 72a6a670ace9061e45136b19ce34b83c4dbca11f Parents: e5f3dd6 Author: tedyu <[email protected]> Authored: Tue Jan 13 10:51:56 2015 -0800 Committer: tedyu <[email protected]> Committed: Tue Jan 13 10:51:56 2015 -0800 ---------------------------------------------------------------------- .../apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/72a6a670/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java index 7866c10..2115978 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java @@ -933,10 +933,12 @@ public class LoadIncrementalHFiles extends Configured implements Tool { } Path hfofDir = new Path(dirPath); - Connection connection = ConnectionFactory.createConnection(getConf()); - HTable table = (HTable) connection.getTable(tableName); - doBulkLoad(hfofDir, table); + try (Connection connection = ConnectionFactory.createConnection(getConf()); + HTable table = (HTable) connection.getTable(tableName);) { + doBulkLoad(hfofDir, table); + } + return 0; }
