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.---
