You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yu...@apache.org on 2020/07/02 16:28:46 UTC
[incubator-iotdb] branch kyy updated: remove lines
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 <yu...@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 {