Github user jrthe42 commented on a diff in the pull request: https://github.com/apache/flink/pull/6301#discussion_r201555590 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSinkBuilder.java --- @@ -115,6 +119,16 @@ public JDBCAppendTableSinkBuilder setParameterTypes(int... types) { return this; } + public JDBCAppendTableSinkBuilder setIdleConnectionCheckInterval(long idleConnectionCheckInterval) { + this.idleConnectionCheckInterval = idleConnectionCheckInterval; + return this; + } + + public JDBCAppendTableSinkBuilder setIdleConnectionCheckTimeout(int idleConnectionCheckTimeout) { --- End diff -- OK, I will add java doc here.
---