diff --git a/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java b/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java index 948914ff190..8415e67e379 100644 --- a/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java +++ b/jdbc/src/main/java/org/apache/zeppelin/jdbc/JDBCInterpreter.java @@ -681,6 +681,11 @@ private InterpreterResult executeSql(String propertyKey, String sql, for (int i = 0; i < sqlArray.size(); i++) { String sqlToExecute = sqlArray.get(i); statement = connection.createStatement(); + + // fetch n+1 rows in order to indicate there's more rows available (for large selects) + statement.setFetchSize(getMaxResult()); + statement.setMaxRows(getMaxResult() + 1); + if (statement == null) { return new InterpreterResult(Code.ERROR, "Prefix not found."); }