diff --git a/beeline/src/java/org/apache/hive/beeline/BeeLine.java b/beeline/src/java/org/apache/hive/beeline/BeeLine.java index 11ff3f2..5f19e65 100644 --- a/beeline/src/java/org/apache/hive/beeline/BeeLine.java +++ b/beeline/src/java/org/apache/hive/beeline/BeeLine.java @@ -881,7 +881,7 @@ int runInit() { } private int embeddedConnect() { - if (!dispatch("!connect " + Utils.URL_PREFIX + " '' ''")) { + if (!execCommandWithPrefix("!connect " + Utils.URL_PREFIX + " '' ''")) { return ERRNO_OTHER; } else { return ERRNO_OK; @@ -1136,11 +1136,7 @@ boolean dispatch(String line) { return commands.sql(line, getOpts().getEntireLineAsCommand()); } } else { - if (line.toLowerCase().startsWith("!connect")) { - return execCommandWithPrefix(line); - } else { - return commands.sql(line, getOpts().getEntireLineAsCommand()); - } + return commands.sql(line, getOpts().getEntireLineAsCommand()); } }