Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6301#discussion_r201558827 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java --- @@ -41,6 +43,8 @@ public class JDBCOutputFormat extends RichOutputFormat<Row> { private static final long serialVersionUID = 1L; static final int DEFAULT_BATCH_INTERVAL = 5000; + static final long DEFAULT_IDLE_CONNECTION_CHECK_INTERVAL = 30 * 60 * 1000; + static final int DEFAULT_IDLE_CONNECTION_CHECK_TIMEOUT = 0; --- End diff -- OK, my wrong, I misunderstand that you make this value as Timer#schedule method's third parameter period
---