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

HBASE-4065 TableOutputFormat ignores failure to create table instance 

(Brock Noland)


git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1160351 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Zhihong Yu 2011-08-22 18:03:34 +00:00
parent 1c90f10c7f
commit 58dfa28fef
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGES.txt
View File

@ -204,6 +204,8 @@ Release 0.91.0 - Unreleased
(Benoît Sigoure) (Benoît Sigoure)
HBASE-4175 Fix FSUtils.createTableDescriptor() (Ramkrishna) HBASE-4175 Fix FSUtils.createTableDescriptor() (Ramkrishna)
HBASE-4008 Problem while stopping HBase (Akash Ashok) HBASE-4008 Problem while stopping HBase (Akash Ashok)
HBASE-4065 TableOutputFormat ignores failure to create table instance
(Brock Noland)
IMPROVEMENTS IMPROVEMENTS
HBASE-3290 Max Compaction Size (Nicolas Spiegelberg via Stack) HBASE-3290 Max Compaction Size (Nicolas Spiegelberg via Stack)

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

@ -178,6 +178,9 @@ implements Configurable {
public void setConf(Configuration otherConf) { public void setConf(Configuration otherConf) {
this.conf = HBaseConfiguration.create(otherConf); this.conf = HBaseConfiguration.create(otherConf);
String tableName = this.conf.get(OUTPUT_TABLE); String tableName = this.conf.get(OUTPUT_TABLE);
if(tableName == null || tableName.length() <= 0) {
throw new IllegalArgumentException("Must specify table name");
}
String address = this.conf.get(QUORUM_ADDRESS); String address = this.conf.get(QUORUM_ADDRESS);
String serverClass = this.conf.get(REGION_SERVER_CLASS); String serverClass = this.conf.get(REGION_SERVER_CLASS);
String serverImpl = this.conf.get(REGION_SERVER_IMPL); String serverImpl = this.conf.get(REGION_SERVER_IMPL);
@ -194,6 +197,7 @@ implements Configurable {
LOG.info("Created table instance for " + tableName); LOG.info("Created table instance for " + tableName);
} catch(IOException e) { } catch(IOException e) {
LOG.error(e); LOG.error(e);
throw new RuntimeException(e);
} }
} }
} }