diff --git beeline/src/java/org/apache/hive/beeline/DeprecatedSeparatedValuesOutputFormat.java beeline/src/java/org/apache/hive/beeline/DeprecatedSeparatedValuesOutputFormat.java index f49daee..c1aea20 100644 --- beeline/src/java/org/apache/hive/beeline/DeprecatedSeparatedValuesOutputFormat.java +++ beeline/src/java/org/apache/hive/beeline/DeprecatedSeparatedValuesOutputFormat.java @@ -45,6 +45,11 @@ public DeprecatedSeparatedValuesOutputFormat(BeeLine beeLine, char separator) { public int print(Rows rows) { int count = 0; while (rows.hasNext()) { + if (count == 0 && !beeLine.getOpts().getShowHeader()) { + rows.next(); + count++; + continue; + } printRow(rows, (Rows.Row) rows.next()); count++; } diff --git beeline/src/java/org/apache/hive/beeline/SeparatedValuesOutputFormat.java beeline/src/java/org/apache/hive/beeline/SeparatedValuesOutputFormat.java index a2c18c7..75441bc 100644 --- beeline/src/java/org/apache/hive/beeline/SeparatedValuesOutputFormat.java +++ beeline/src/java/org/apache/hive/beeline/SeparatedValuesOutputFormat.java @@ -64,6 +64,11 @@ public int print(Rows rows) { int count = 0; while (rows.hasNext()) { + if (count == 0 && !beeLine.getOpts().getShowHeader()) { + rows.next(); + count++; + continue; + } printRow(rows, (Rows.Row) rows.next()); count++; }