diff --git a/flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/FlinkConnection.java b/flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/FlinkConnection.java index 72d354de6e536..56613e7281215 100644 --- a/flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/FlinkConnection.java +++ b/flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/FlinkConnection.java @@ -83,6 +83,13 @@ public Statement createStatement() throws SQLException { return statement; } + // TODO We currently do not support this, but we can't throw a SQLException here because we want + // to support jdbc tools such as Tableau. + @Override + public boolean isValid(int timeout) throws SQLException { + return true; + } + // TODO We currently do not support this, but we can't throw a SQLException here because we want // to support jdbc tools such as beeline and sqlline. @Override