fix: change to nanoseconds

PeterZh6 · Sep 18, 2024 · a14f111 · a14f111
1 parent e52d89c
commit a14f111
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...es-cdc/src/main/java/org/apache/inlong/sort/postgre/RowDataDebeziumDeserializeSchema.java b/...es-cdc/src/main/java/org/apache/inlong/sort/postgre/RowDataDebeziumDeserializeSchema.java
@@ -136,9 +136,9 @@ public void open() {
 
     @Override
     public void deserialize(SourceRecord record, Collector<RowData> out) throws Exception {
-        long deseializeStartTime = System.currentTimeMillis();
+        long deserializeStartTime = System.nanoTime();
         try {
-            doDeserialize(record, out, deseializeStartTime);
+            doDeserialize(record, out, deserializeStartTime);
         } catch (Exception e) {
             if (sourceExactlyMetric != null) {
                 sourceExactlyMetric.incNumDeserializeError();
@@ -186,7 +186,7 @@ private void doDeserialize(SourceRecord record, Collector<RowData> out, long des
         }
         if (sourceExactlyMetric != null) {
             sourceExactlyMetric.incNumDeserializeSuccess();
-            sourceExactlyMetric.recordDeserializeDelay(System.currentTimeMillis() - deserializeStartTime);
+            sourceExactlyMetric.recordDeserializeDelay(System.nanoTime() - deserializeStartTime);
         }
     }