[INLONG-10193][Sort] fix format and bug.

apache · May 14, 2024 · 9f32ac5 · 9f32ac5
1 parent 9098c22
commit 9f32ac5
Showing 1 changed file with 2 additions and 2 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
@@ -138,7 +138,7 @@ public void deserialize(SourceRecord record, Collector<RowData> out) throws Exce
             GenericRowData insert = extractAfterRow(value, valueSchema);
             validator.validate(insert, RowKind.INSERT);
             insert.setRowKind(RowKind.INSERT);
-            if (sourceMetricData != null){
+            if (sourceMetricData != null) {
                 out = new MetricsCollector<>(out, sourceMetricData);
             }
             emit(record, insert, out);
@@ -158,7 +158,7 @@ public void deserialize(SourceRecord record, Collector<RowData> out) throws Exce
             GenericRowData after = extractAfterRow(value, valueSchema);
             validator.validate(after, RowKind.UPDATE_AFTER);
             after.setRowKind(RowKind.UPDATE_AFTER);
-            if (sourceMetricData != null){
+            if (sourceMetricData != null) {
                 out = new MetricsCollector<>(out, sourceMetricData);
             }
             emit(record, after, out);