diff --git a/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java b/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java index 68741f67da..06764c7160 100644 --- a/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java +++ b/cli/src/java/org/apache/hadoop/hive/cli/CliDriver.java @@ -463,7 +463,7 @@ public int processReader(BufferedReader r) throws IOException { while ((line = r.readLine()) != null) { // Skipping through comments - if (! line.startsWith("--")) { + if (! line.trim().startsWith("--")) { qsb.append(line + "\n"); } } diff --git a/common/src/java/org/apache/hadoop/hive/common/cli/HiveFileProcessor.java b/common/src/java/org/apache/hadoop/hive/common/cli/HiveFileProcessor.java index 62d85605bd..3d6d77fae6 100644 --- a/common/src/java/org/apache/hadoop/hive/common/cli/HiveFileProcessor.java +++ b/common/src/java/org/apache/hadoop/hive/common/cli/HiveFileProcessor.java @@ -59,7 +59,7 @@ protected int processReader(BufferedReader reader) throws IOException { String line; StringBuilder qsb = new StringBuilder(); while ((line = reader.readLine()) != null) { - if (!line.startsWith("--")) { + if (!line.trim().startsWith("--")) { qsb.append(line); } }