Refactor instrumentation

spotify · Jul 8, 2019 · bdeec3b · bdeec3b
1 parent e3c70c0
commit bdeec3b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dbeam-core/src/main/java/com/spotify/dbeam/avro/JdbcAvroIO.java b/dbeam-core/src/main/java/com/spotify/dbeam/avro/JdbcAvroIO.java
@@ -210,7 +210,7 @@ public void write(String query) throws Exception {
         final long startMs = metering.startWriteMeter();
         convertAllResultSet(resultSet, JdbcAvroRecordConverter.create(resultSet));
         queue.put(ByteBuffer.allocate(0)); // write final record, so that consumer stops
-        final long startMs2 = metering.startWriteMeter();
+        final long startMs2 = System.currentTimeMillis();
         future.get();
         executorService.shutdown();
         LOGGER.info(String.format("jdbcavroio : Waited %5.2f seconds for finishing write operation",