Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-20295 fix NullPointException in TableOutputFormat.checkOutputSpecs

This commit is contained in:
michael.jin 2018-03-29 07:06:10 +08:00 committed by Michael Stack
parent 2cfa344ab1
commit 10ed3f41f5
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableOutputFormat.java
View File

@ -174,9 +174,13 @@ implements Configurable {
@Override @Override
public void checkOutputSpecs(JobContext context) throws IOException, public void checkOutputSpecs(JobContext context) throws IOException,
InterruptedException { InterruptedException {
Configuration hConf = context.getConfiguration();
if(hConf == null) {
hConf = this.conf;
}
try (Admin admin = ConnectionFactory.createConnection(getConf()).getAdmin()) { try (Admin admin = ConnectionFactory.createConnection(hConf).getAdmin()) {
TableName tableName = TableName.valueOf(this.conf.get(OUTPUT_TABLE)); TableName tableName = TableName.valueOf(hConf.get(OUTPUT_TABLE));
if (!admin.tableExists(tableName)) { if (!admin.tableExists(tableName)) {
throw new TableNotFoundException("Can't write, table does not exist:" + throw new TableNotFoundException("Can't write, table does not exist:" +
tableName.getNameAsString()); tableName.getNameAsString());