fix checkstyle error

xwm1992 · Jul 26, 2024 · 33bbbe4 · 33bbbe4
1 parent d828391
commit 33bbbe4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...main/java/org/apache/eventmesh/connector/canal/source/connector/CanalSourceConnector.java b/...main/java/org/apache/eventmesh/connector/canal/source/connector/CanalSourceConnector.java
@@ -199,10 +199,10 @@ private Canal buildCanal(CanalSourceConfig sourceConfig) {
                 recordPositionMap.put("timestamp", canalRecordPartition.getTimeStamp());
                 recordPositionMap.put("position", canalRecordOffset.getOffset());
                 // for mariaDB not support gtid mode
-                if(sourceConfig.isGTIDMode() && !sourceConfig.isMariaDB()) {
+                if (sourceConfig.isGTIDMode() && !sourceConfig.isMariaDB()) {
                     String gtidRange = canalRecordOffset.getGtid();
                     if (gtidRange != null) {
-                        if (canalRecordOffset.getCurrentGtid() != null ) {
+                        if (canalRecordOffset.getCurrentGtid() != null) {
                             gtidRange = EntryParser.replaceGtidRange(canalRecordOffset.getGtid(), canalRecordOffset.getCurrentGtid(),
                                 sourceConfig.getServerUUID());
                         }