[shardingsphere] branch master updated: Optimize ScalingTaskScheduler (#9254)

[menghaoran]

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

menghaoran 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 88a59c7  Optimize ScalingTaskScheduler (#9254)
88a59c7 is described below

commit 88a59c7c9ffb7f1ab9caeef10cbe20881d9be271
Author: 邱鹿 Lucas <lucas...@163.com>
AuthorDate: Mon Feb 1 17:51:24 2021 +0800

    Optimize ScalingTaskScheduler (#9254)
    
    Co-authored-by: qiulu3 <Lucas209910>
---
 .../shardingsphere/scaling/core/execute/engine/TaskExecuteEngine.java   | 2 +-
 .../shardingsphere/scaling/core/schedule/ScalingTaskScheduler.java      | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/execute/engine/TaskExecuteEngine.java
 
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/execute/engine/TaskExecuteEngine.java
index 1ccc068..7ad5db1 100644
--- 
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/execute/engine/TaskExecuteEngine.java
+++ 
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/execute/engine/TaskExecuteEngine.java
@@ -40,7 +40,7 @@ import java.util.concurrent.Future;
 @RequiredArgsConstructor(access = AccessLevel.PRIVATE)
 public final class TaskExecuteEngine {
     
-    public static final String THREAD_NAME_FORMAT = 
"ShardingScaling-execute-%d";
+    public static final String THREAD_NAME_FORMAT = "Scaling-execute-%d";
     
     private final ListeningExecutorService executorService;
     
diff --git 
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/schedule/ScalingTaskScheduler.java
 
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/schedule/ScalingTaskScheduler.java
index 4687fc8..5ce72a2 100644
--- 
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/schedule/ScalingTaskScheduler.java
+++ 
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/schedule/ScalingTaskScheduler.java
@@ -110,7 +110,7 @@ public final class ScalingTaskScheduler implements Runnable 
{
     }
     
     private synchronized void executeIncrementalTask() {
-        if 
(JobStatus.EXECUTE_INCREMENTAL_TASK.name().equals(jobContext.getStatus())) {
+        if (JobStatus.EXECUTE_INCREMENTAL_TASK.equals(jobContext.getStatus())) 
{
             return;
         }
         log.info("-------------- Start incremental task --------------");