diff --git beeline/src/java/org/apache/hive/beeline/BeeLine.java beeline/src/java/org/apache/hive/beeline/BeeLine.java index 66185f6..11e9393 100644 --- beeline/src/java/org/apache/hive/beeline/BeeLine.java +++ beeline/src/java/org/apache/hive/beeline/BeeLine.java @@ -2025,10 +2025,14 @@ int print(ResultSet rs) throws SQLException { Rows rows; - if (getOpts().getIncremental()) { - rows = new IncrementalRows(this, rs); + if (f instanceof TableOutputFormat) { + if (getOpts().getIncremental()) { + rows = new IncrementalRows(this, rs); + } else { + rows = new BufferedRows(this, rs); + } } else { - rows = new BufferedRows(this, rs); + rows = new IncrementalRows(this, rs); } return f.print(rows); }