diff --git ql/src/java/org/apache/hadoop/hive/ql/processors/CommandProcessorFactory.java ql/src/java/org/apache/hadoop/hive/ql/processors/CommandProcessorFactory.java index 2be6f26..c299981 100644 --- ql/src/java/org/apache/hadoop/hive/ql/processors/CommandProcessorFactory.java +++ ql/src/java/org/apache/hadoop/hive/ql/processors/CommandProcessorFactory.java @@ -72,6 +72,11 @@ public static CommandProcessor getForHiveCommandInternal(String[] cmd, HiveConf if (!availableCommands.contains(cmd[0].trim().toLowerCase())) { throw new SQLException("Insufficient privileges to execute " + cmd[0], "42000"); } + if (cmd.length > 1 && "reload".equalsIgnoreCase(cmd[0]) + && "function".equalsIgnoreCase(cmd[1])) { + // special handling for SQL "reload function" + return null; + } switch (hiveCommand) { case SET: return new SetProcessor(); diff --git ql/src/java/org/apache/hadoop/hive/ql/processors/HiveCommand.java ql/src/java/org/apache/hadoop/hive/ql/processors/HiveCommand.java index 58becda..145808b 100644 --- ql/src/java/org/apache/hadoop/hive/ql/processors/HiveCommand.java +++ ql/src/java/org/apache/hadoop/hive/ql/processors/HiveCommand.java @@ -75,12 +75,7 @@ public static HiveCommand find(String[] command, boolean findOnlyForTesting) { } else if(command.length > 1 && "from".equalsIgnoreCase(command[1])) { //special handling for SQL "delete from where..." return null; - } else if(command.length > 1 && "reload".equalsIgnoreCase(command[0]) - && "function".equalsIgnoreCase(command[1])) { - //special handling for SQL "reload function" - return null; - } - else if(command.length > 1 && "set".equalsIgnoreCase(command[0]) && "autocommit".equalsIgnoreCase(command[1])) { + } else if(command.length > 1 && "set".equalsIgnoreCase(command[0]) && "autocommit".equalsIgnoreCase(command[1])) { return null;//don't want set autocommit true|false to get mixed with set hive.foo.bar... } else if (COMMANDS.contains(cmd)) { HiveCommand hiveCommand = HiveCommand.valueOf(cmd);