diff --git a/beeline/src/java/org/apache/hive/beeline/BeeLine.java b/beeline/src/java/org/apache/hive/beeline/BeeLine.java index 4ae2e3f81b..bc329208c9 100644 --- a/beeline/src/java/org/apache/hive/beeline/BeeLine.java +++ b/beeline/src/java/org/apache/hive/beeline/BeeLine.java @@ -1126,6 +1126,14 @@ private String getDefaultConnectionUrl(CommandLine cl) throws BeelineConfFilePar } if (jdbcConnectionParams != null) { + String userName = cl.getOptionValue("n"); + if (userName != null) { + jdbcConnectionParams.getSessionVars().put(JdbcConnectionParams.AUTH_USER, userName); + } + String password = cl.getOptionValue("p"); + if (password != null) { + jdbcConnectionParams.getSessionVars().put(JdbcConnectionParams.AUTH_PASSWD, password); + } mergedConnectionProperties = HS2ConnectionFileUtils.mergeUserConnectionPropertiesAndBeelineSite( userConnectionProperties, jdbcConnectionParams);