[incubator-iotdb] branch kyy updated: remove lines

[yuyuankang]

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

yuyuankang pushed a commit to branch kyy
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/kyy by this push:
     new 0fb4c01  remove lines
0fb4c01 is described below

commit 0fb4c019f36a5cb11456d72b79c27cf45416c5a6
Author: Ring-k <yuyuank...@hotmail.com>
AuthorDate: Fri Jul 3 00:28:28 2020 +0800

    remove lines
---
 .../java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java   | 3 ---
 1 file changed, 3 deletions(-)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
 
b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
index 3d67e49..96e327d 100644
--- 
a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
+++ 
b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
@@ -1515,9 +1515,7 @@ public class MetaGroupMember extends RaftMember 
implements TSMetaService.AsyncIf
     if(plan instanceof DeleteTimeSeriesPlan){
       List<Path> originalPaths = ((DeleteTimeSeriesPlan)plan).getPaths();
       ConcurrentSkipListSet<Path> fullPaths = new ConcurrentSkipListSet<>();
-
       ExecutorService getAllPathsService = 
Executors.newFixedThreadPool(partitionTable.getGlobalGroups().size());
-
       for(Path path : originalPaths){
         String pathStr = path.getFullPath();
         getAllPathsService.submit(()->{
@@ -1538,7 +1536,6 @@ public class MetaGroupMember extends RaftMember 
implements TSMetaService.AsyncIf
         Thread.currentThread().interrupt();
         logger.error("Unexpected interruption when waiting for get all paths 
services to stop", e);
       }
-
       ((DeleteTimeSeriesPlan)plan).setPaths(new ArrayList<>(fullPaths));
     }
     try {