You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2020/11/27 13:29:55 UTC

[shardingsphere] branch master updated: Add log for scheduled executor. (#8387)

This is an automated email from the ASF dual-hosted git repository.

zhangyonglun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 0ea57c1  Add log for scheduled executor. (#8387)
0ea57c1 is described below

commit 0ea57c1f8bb2165b09b46addc7b2e304b4695725
Author: 邱鹿 Lucas <lu...@163.com>
AuthorDate: Fri Nov 27 21:25:12 2020 +0800

    Add log for scheduled executor. (#8387)
    
    Co-authored-by: qiulu3 <Lucas209910>
---
 .../job/position/resume/RepositoryResumeBreakPointManager.java | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/RepositoryResumeBreakPointManager.java b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/RepositoryResumeBreakPointManager.java
index 416f09d..462a207 100644
--- a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/RepositoryResumeBreakPointManager.java
+++ b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/RepositoryResumeBreakPointManager.java
@@ -57,8 +57,14 @@ public final class RepositoryResumeBreakPointManager extends AbstractResumeBreak
     }
     
     private void persistPosition() {
-        persistIncrementalPosition();
-        persistInventoryPosition();
+        try {
+            persistIncrementalPosition();
+            persistInventoryPosition();
+            // CHECKSTYLE:OFF
+        } catch (final Exception ex) {
+            // CHECKSTYLE:ON
+            log.error("persist position failed.", ex);
+        }
     }
     
     @Override