Move AbstractLifecycleExecutor to core module

apache · Nov 4, 2023 · f4c2578 · f4c2578
1 parent d618295
commit f4c2578
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/...ava/org/apache/shardingsphere/data/pipeline/common/execute/AbstractLifecycleExecutor.java b/...ava/org/apache/shardingsphere/data/pipeline/common/execute/AbstractLifecycleExecutor.java
@@ -53,9 +53,6 @@ public final void start() {
         runBlocking();
     }
 
-    /**
-     * Run blocking.
-     */
     protected abstract void runBlocking();
 
     @Override

diff --git a/...ain/java/org/apache/shardingsphere/data/pipeline/opengauss/ingest/OpenGaussWALDumper.java b/...ain/java/org/apache/shardingsphere/data/pipeline/opengauss/ingest/OpenGaussWALDumper.java
@@ -96,7 +96,7 @@ protected void runBlocking() {
                 int times = reconnectTimes.incrementAndGet();
                 log.error("Connect failed, reconnect times={}", times, ex);
                 if (isRunning()) {
-                    Thread.sleep(5000);
+                    Thread.sleep(5000L);
                 }
                 if (times >= 5) {
                     throw new IngestException(ex);