HBASE-26019 Remove the reflection and call Configuration.getPassword() directly. (#3408)

Reviewed-by: Viraj Jasani <vjasani@apache.org>
Reviewed-by: Wellington Chevreuil <wchevreuil@apache.org>
Reviewed-by: litao <tomleescut@gmail.com>
This commit is contained in:
Wei-Chiu Chuang 2021-06-22 18:15:02 -07:00 committed by Peter Somogyi
parent 1a9ddb6694
commit cb247f9464
1 changed files with 8 additions and 29 deletions

View File

@ -200,35 +200,14 @@ public class HBaseConfiguration extends Configuration {
*/
public static String getPassword(Configuration conf, String alias,
String defPass) throws IOException {
String passwd = null;
try {
Method m = Configuration.class.getMethod("getPassword", String.class);
char[] p = (char[]) m.invoke(conf, alias);
if (p != null) {
LOG.debug(String.format("Config option \"%s\" was found through" +
" the Configuration getPassword method.", alias));
passwd = new String(p);
} else {
LOG.debug(String.format(
"Config option \"%s\" was not found. Using provided default value",
alias));
passwd = defPass;
}
} catch (NoSuchMethodException e) {
// this is a version of Hadoop where the credential
//provider API doesn't exist yet
LOG.debug(String.format(
"Credential.getPassword method is not available." +
" Falling back to configuration."));
passwd = conf.get(alias, defPass);
} catch (SecurityException e) {
throw new IOException(e.getMessage(), e);
} catch (IllegalAccessException e) {
throw new IOException(e.getMessage(), e);
} catch (IllegalArgumentException e) {
throw new IOException(e.getMessage(), e);
} catch (InvocationTargetException e) {
throw new IOException(e.getMessage(), e);
String passwd;
char[] p = conf.getPassword(alias);
if (p != null) {
LOG.debug("Config option {} was found through the Configuration getPassword method.", alias);
passwd = new String(p);
} else {
LOG.debug("Config option {} was not found. Using provided default value", alias);
passwd = defPass;
}
return passwd;
}