From 7026b600c6bf0fd4b0225f946efa1ea3d5c4db7a Mon Sep 17 00:00:00 2001 From: Zachary Auclair Date: Thu, 23 May 2024 20:00:12 -0400 Subject: [PATCH] feat(flink-connection): support isValid for tableau --- .../java/org/apache/flink/table/jdbc/FlinkConnection.java | 7 +++++++ 1 file changed, 7 insertions(+) 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