[GitHub] [incubator-iotdb] LebronAl commented on a change in pull request #1457: delete timeseries when path is not found

[GitBox]

LebronAl commented on a change in pull request #1457:
URL: https://github.com/apache/incubator-iotdb/pull/1457#discussion_r449783967



##########
File path: 
cluster/src/main/java/org/apache/iotdb/cluster/server/member/MetaGroupMember.java
##########
@@ -1522,6 +1532,44 @@ private TSStatus 
processNonPartitionedDataPlan(PhysicalPlan plan) {
     }
   }
 
+  DeleteTimeSeriesPlan 
getDeleteTimeseriesPlanWithFullPaths(DeleteTimeSeriesPlan plan)
+      throws PathNotExistException {
+    List<Path> originalPaths = plan.getPaths();
+    ConcurrentSkipListSet<Path> fullPaths = new ConcurrentSkipListSet<>();
+    ConcurrentSkipListSet<String> nonExistPaths = new 
ConcurrentSkipListSet<>();
+    ExecutorService getAllPathsService = Executors
+        .newFixedThreadPool(partitionTable.getGlobalGroups().size());
+    for (Path path : originalPaths) {
+      String pathStr = path.getFullPath();
+      getAllPathsService.submit(() -> {
+        try {
+          List<String> fullPathStrs = getMatchedPaths(pathStr);
+          if (fullPathStrs.size() == 0) {
+            nonExistPaths.add(pathStr);
+            logger.error("Path {} is not found.", pathStr);
+          }
+          for (String fullPathStr : fullPathStrs) {
+            fullPaths.add(new Path(fullPathStr));
+          }
+        } catch (MetadataException e) {
+          logger.error("Failed to get full paths of the prefix path: {} 
because {}.", pathStr, e);

Review comment:
       remove last `{}` or use e.getMessage()




----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org