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