Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6301#discussion_r201551945 --- Diff: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java --- @@ -54,6 +58,10 @@ private Connection dbConn; private PreparedStatement upload; + private long idleConnectionCheckInterval = DEFAULT_IDLE_CONNECTION_CHECK_INTERVAL; + private int idleConnectionCheckTimeOut = DEFAULT_IDLE_CONNECTION_CHECK_TIMEOUT; --- End diff -- change the variable to `idleConnectionCheckTimeout ` looks better to me
---