Index: cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java =================================================================== --- cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java (revision 1051372) +++ cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java (working copy) @@ -250,11 +250,14 @@ StringBuilder qsb = new StringBuilder(); while ((line = r.readLine()) != null) { - qsb.append(line + "\n"); + qsb.append(removeComment(line) + "\n"); } return (processLine(qsb.toString())); } + private String removeComment(String line) { + return line.replaceFirst("--.+$","").trim(); + } public int processFile(String fileName) throws IOException { FileReader fileReader = null;