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


---

Reply via email to