From b9ae3935bc60054e4eac094450d83c6c78d02bcb Mon Sep 17 00:00:00 2001
From: hebelala <hebelala@qq.com>
Date: Fri, 17 Nov 2017 18:53:07 +0800
Subject: [PATCH] #290 code review commit

---
 .../java/com/vip/saturn/it/impl/ShardingWithTrafficIT.java  | 4 ++--
 .../listener/ExecutorTrafficTriggerShardingListener.java    | 2 +-
 .../job/sharding/service/NamespaceShardingService.java      | 6 +++---
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/saturn-it/src/test/java/com/vip/saturn/it/impl/ShardingWithTrafficIT.java b/saturn-it/src/test/java/com/vip/saturn/it/impl/ShardingWithTrafficIT.java
index cc1b26089..b51b601c9 100644
--- a/saturn-it/src/test/java/com/vip/saturn/it/impl/ShardingWithTrafficIT.java
+++ b/saturn-it/src/test/java/com/vip/saturn/it/impl/ShardingWithTrafficIT.java
@@ -47,8 +47,8 @@ public static void tearDown() throws Exception {
      */
     @Test
     public void test_A_NormalFlow() throws Exception {
-        String jobName = "test_A_Extract";
-        String jobName2 = "test_A_Extract2";
+        String jobName = "test_A_NormalFlow";
+        String jobName2 = "test_A_NormalFlow2";
 
         final JobConfiguration jobConfiguration = new JobConfiguration(jobName);
         jobConfiguration.setCron("* * * * * ? 2099");
diff --git a/saturn-job-sharding/src/main/java/com/vip/saturn/job/sharding/listener/ExecutorTrafficTriggerShardingListener.java b/saturn-job-sharding/src/main/java/com/vip/saturn/job/sharding/listener/ExecutorTrafficTriggerShardingListener.java
index 51e43ddbb..bdfcf53eb 100644
--- a/saturn-job-sharding/src/main/java/com/vip/saturn/job/sharding/listener/ExecutorTrafficTriggerShardingListener.java
+++ b/saturn-job-sharding/src/main/java/com/vip/saturn/job/sharding/listener/ExecutorTrafficTriggerShardingListener.java
@@ -23,7 +23,7 @@ public void childEvent(Type type, String path, String nodeData) throws Exception
         try {
             if (isExecutorNoTraffic(type, path)) {
                 String executorName = SaturnExecutorsNode.getExecutorNameByNoTrafficPath(path);
-                namespaceShardingService.asyncShardingWhenExecutorExtractTraffic(executorName);
+                namespaceShardingService.asyncShardingWhenExtractExecutorTraffic(executorName);
             } else if (isExecutorTraffic(type, path)) {
                 String executorName = SaturnExecutorsNode.getExecutorNameByNoTrafficPath(path);
                 namespaceShardingService.asyncShardingWhenRecoverExecutorTraffic(executorName);
diff --git a/saturn-job-sharding/src/main/java/com/vip/saturn/job/sharding/service/NamespaceShardingService.java b/saturn-job-sharding/src/main/java/com/vip/saturn/job/sharding/service/NamespaceShardingService.java
index 205c2f1f8..18fef7986 100644
--- a/saturn-job-sharding/src/main/java/com/vip/saturn/job/sharding/service/NamespaceShardingService.java
+++ b/saturn-job-sharding/src/main/java/com/vip/saturn/job/sharding/service/NamespaceShardingService.java
@@ -1074,7 +1074,7 @@ protected boolean pick(List<String> allJobs, List<String> allEnableJobs, List<Sh
 			}
 
 			if (theExecutor == null) {
-				LOGGER.info("The executor {} is offline or already noTraffic, unnecessary to extract traffic", executorName);
+				LOGGER.warn("The executor {} maybe offline, unnecessary to extract traffic", executorName);
 				return false;
 			}
 
@@ -1123,7 +1123,7 @@ protected boolean pick(List<String> allJobs, List<String> allEnableJobs, List<Sh
 				}
 			}
 			if (theExecutor == null) {
-				LOGGER.info("The executor {} is offline, unnecessary to recover traffic", executorName);
+				LOGGER.warn("The executor {} maybe offline, unnecessary to recover traffic", executorName);
 				return false;
 			}
 
@@ -1696,7 +1696,7 @@ public void asyncShardingWhenExecutorOffline(String executorName) throws Excepti
 	/**
 	 * 摘取流量
 	 */
-	public void asyncShardingWhenExecutorExtractTraffic(String executorName) throws Exception {
+	public void asyncShardingWhenExtractExecutorTraffic(String executorName) throws Exception {
 		if (isLeadership()) {
 			shardingCount.incrementAndGet();
 			executorService.submit(new ExecuteExtractTrafficShardingTask(executorName));