Repository: hbase Updated Branches: refs/heads/branch-2 8d60a89c3 -> 421ed6ca5 refs/heads/branch-2.0 9e3b28804 -> c15fd6b00 refs/heads/master 0dcae90ea -> c51e9adc7
Revert "change getConf as first sequence instead of jobContext in TableOutputFormat.checkOutputSpec, add unit tests" This reverts commit 9e68719014a62f37e7559329e44e2df49738ef6c. Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/d91908b0 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/d91908b0 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/d91908b0 Branch: refs/heads/branch-2 Commit: d91908b0d46156fa364ba11d476b9cdbc01d0411 Parents: 8d60a89 Author: Mike Drob <md...@apache.org> Authored: Tue May 8 22:18:42 2018 -0500 Committer: Mike Drob <md...@apache.org> Committed: Tue May 8 22:18:42 2018 -0500 ---------------------------------------------------------------------- .../org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/d91908b0/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java ---------------------------------------------------------------------- diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java index 78be5af..0a1928b 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java @@ -174,9 +174,9 @@ implements Configurable { @Override public void checkOutputSpecs(JobContext context) throws IOException, InterruptedException { - Configuration hConf = getConf(); - if (hConf == null) { - hConf = context.getConfiguration(); + Configuration hConf = context.getConfiguration(); + if(hConf == null) { + hConf = this.conf; } try (Admin admin = ConnectionFactory.createConnection(hConf).getAdmin()) {