Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4725#discussion_r192222445
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
---
@@ -82,6 +97,22 @@ public void open(int taskNumber, int numTasks) throws
IOException {
} catch (ClassNotFoundException cnfe) {
throw new IllegalArgumentException("JDBC driver class
not found.", cnfe);
}
+ this.flushMeter = getRuntimeContext()
+ .getMetricGroup()
+ .addGroup(FLUSH_SCOPE)
+ .meter(FLUSH_RATE_METER_NAME, new
DropwizardMeterWrapper(new com.codahale.metrics.Meter()));
--- End diff --
These could be replaced with the built-in `MeterView`.
---
