Github user laurentgo commented on a diff in the pull request:
https://github.com/apache/drill/pull/858#discussion_r149230118
--- Diff:
exec/jdbc/src/main/java/org/apache/drill/jdbc/impl/DrillResultSetImpl.java ---
@@ -98,6 +103,34 @@ private void throwIfClosed() throws
AlreadyClosedSqlException,
}
}
+ /**
+ * Throws SqlTimeoutException if the statement has already timed out
+ * @throws AlreadyClosedSqlException if Connection is closed
+ * @throws SqlTimeoutException if Statement is already timed out
+ */
+ private void throwIfTimedOut() throws AlreadyClosedSqlException,
+ SqlTimeoutException,
+ SQLException {
+ if ( ((DrillStatement) statement).isTimedOut() ) {
+ //TODO
+// if ( (statement instanceof DrillStatementImpl &&
((DrillStatementImpl) statement).isTimedOut()) ||
--- End diff --
to be removed?
---
