Github user zentol commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4725#discussion_r192222532
  
    --- Diff: 
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
 ---
    @@ -58,6 +68,11 @@
     
        private int[] typesArray;
     
    +   private Meter batchLimitReachedMeter;
    +   private Meter flushMeter;
    --- End diff --
    
    These could be initialized in the constructor and made final.


---

Reply via email to