diff --git beeline/src/java/org/apache/hive/beeline/HiveSchemaTool.java beeline/src/java/org/apache/hive/beeline/HiveSchemaTool.java index 96b2978..c7e7b74 100644 --- beeline/src/java/org/apache/hive/beeline/HiveSchemaTool.java +++ beeline/src/java/org/apache/hive/beeline/HiveSchemaTool.java @@ -90,13 +90,6 @@ public HiveSchemaTool(String hiveHome, HiveConf hiveConf, String dbType) this.hiveConf = hiveConf; this.dbType = dbType; this.metaStoreSchemaInfo = new MetaStoreSchemaInfo(hiveHome, hiveConf, dbType); - userName = hiveConf.get(ConfVars.METASTORE_CONNECTION_USER_NAME.varname); - try { - passWord = ShimLoader.getHadoopShims().getPassword(hiveConf, - HiveConf.ConfVars.METASTOREPWD.varname); - } catch (IOException err) { - throw new HiveMetaException("Error getting metastore password", err); - } } public HiveConf getHiveConf() { @@ -964,9 +957,19 @@ public static void main(String[] args) { if (line.hasOption("userName")) { schemaTool.setUserName(line.getOptionValue("userName")); + } else { + schemaTool.setUserName( + schemaTool.getHiveConf().get(ConfVars.METASTORE_CONNECTION_USER_NAME.varname)); } if (line.hasOption("passWord")) { schemaTool.setPassWord(line.getOptionValue("passWord")); + } else { + try { + schemaTool.setPassWord(ShimLoader.getHadoopShims().getPassword(schemaTool.getHiveConf(), + HiveConf.ConfVars.METASTOREPWD.varname)); + } catch (IOException err) { + throw new HiveMetaException("Error getting metastore password", err); + } } if (line.hasOption("dryRun")) { schemaTool.setDryRun(true);