test

mxsm · Sep 17, 2023 · 4a8873c · 4a8873c
1 parent f2feac7
commit 4a8873c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/TaskManagerCoordinator.java b/...jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/TaskManagerCoordinator.java
@@ -76,7 +76,7 @@ public void init() {
                 return;
             }
             records.forEach(record -> {
-                try {
+                try { 
                     recordBlockingQueue.put(record);
                 } catch (InterruptedException e) {
                     throw new RuntimeException(e);