From 73c42c0a2653a9b39816184178c507bd260a2c76 Mon Sep 17 00:00:00 2001 From: "michael.jin" Date: Wed, 28 Mar 2018 14:52:22 +0800 Subject: [PATCH] HBASE-20295 fix NullPointException in TableOutputFormat.checkOutputSpecs --- .../java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java index 443d4b2d97..d8b8205f46 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java @@ -173,9 +173,13 @@ implements Configurable { @Override public void checkOutputSpecs(JobContext context) throws IOException, InterruptedException { + Configuration hConf = context.getConfiguration(); + if(hConf == null) { + hConf = this.conf; + } - try (Admin admin = ConnectionFactory.createConnection(getConf()).getAdmin()) { - TableName tableName = TableName.valueOf(this.conf.get(OUTPUT_TABLE)); + try (Admin admin = ConnectionFactory.createConnection(hConf).getAdmin()) { + TableName tableName = TableName.valueOf(hConf.get(OUTPUT_TABLE)); if (!admin.tableExists(tableName)) { throw new TableNotFoundException("Can't write, table does not exist:" + tableName.getNameAsString()); -- 2.14.1