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

HBASE-15628 Implement an AsyncOutputStream which can work with any FileSystem implementation; ADDENDUM -- Change Log output

This commit is contained in:
Michael Stack 2017-12-06 11:35:54 -08:00
parent b2f9b7bc19
commit 52ffa68f8b
No known key found for this signature in database
GPG Key ID: 9816C7FC8ACC93D2
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hbase-server/src/main/java/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputHelper.java
View File

@ -409,11 +409,13 @@ public final class FanOutOneBlockAsyncDFSOutputHelper {
private static PBHelper createPBHelper() throws NoSuchMethodException { private static PBHelper createPBHelper() throws NoSuchMethodException {
Class<?> helperClass; Class<?> helperClass;
String clazzName = "org.apache.hadoop.hdfs.protocolPB.PBHelperClient";
try { try {
helperClass = Class.forName("org.apache.hadoop.hdfs.protocolPB.PBHelperClient"); helperClass = Class.forName(clazzName);
} catch (ClassNotFoundException e) { } catch (ClassNotFoundException e) {
LOG.debug("No PBHelperClient class found, should be hadoop 2.7-", e);
helperClass = org.apache.hadoop.hdfs.protocolPB.PBHelper.class; helperClass = org.apache.hadoop.hdfs.protocolPB.PBHelper.class;
LOG.debug("" + clazzName + " not found (Hadoop is pre-2.8.0?); using " +
helperClass.toString() + " instead.");
} }
Method convertEBMethod = helperClass.getMethod("convert", ExtendedBlock.class); Method convertEBMethod = helperClass.getMethod("convert", ExtendedBlock.class);
Method convertTokenMethod = helperClass.getMethod("convert", Token.class); Method convertTokenMethod = helperClass.getMethod("convert", Token.class);