style

PeterZh6 · Sep 25, 2024 · 3fdce6b · 3fdce6b
1 parent 7eccd60
commit 3fdce6b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/Constants.java b/inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/Constants.java
@@ -83,7 +83,7 @@ public final class Constants {
 
     public static final String NUM_SERIALIZE_SUCCESS = "numSerializeSuccess";
 
-    public static final String NUM_SERIALIZE_ERROR= "numSerializeError";
+    public static final String NUM_SERIALIZE_ERROR = "numSerializeError";
 
     public static final String SERIALIZE_TIME_LAG = "serializeTimeLag";
 

diff --git a/...t/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SinkExactlyMetric.java b/...t/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SinkExactlyMetric.java
@@ -17,11 +17,11 @@
 
 package org.apache.inlong.sort.base.metric;
 
-import org.apache.flink.metrics.Gauge;
 import org.apache.inlong.audit.AuditReporterImpl;
 import org.apache.inlong.sort.base.metric.MetricOption.RegisteredMetric;
 
 import org.apache.flink.metrics.Counter;
+import org.apache.flink.metrics.Gauge;
 import org.apache.flink.metrics.Meter;
 import org.apache.flink.metrics.MetricGroup;
 import org.apache.flink.metrics.SimpleCounter;
@@ -264,11 +264,10 @@ public void registerMetricForNumSnapshotComplete(Counter counter) {
     }
 
     public void registerMetricForSnapshotToCheckpointTimeLag() {
-        snapshotToCheckpointTimeLag = registerGauge(SNAPSHOT_TO_CHECKPOINT_TIME_LAG, (Gauge<Long>) this::getSnapshotToCheckpointDelay);
+        snapshotToCheckpointTimeLag =
+                registerGauge(SNAPSHOT_TO_CHECKPOINT_TIME_LAG, (Gauge<Long>) this::getSnapshotToCheckpointDelay);
     }
 
-
-
     public Counter getNumRecordsOut() {
         return numRecordsOut;
     }