private <V> void checkResults(List<Future<V>> tasks, String errorMsg) {
    for (Future<V> task : tasks) {
      try {
        task.get();
      } catch (ExecutionException e) {
        throw new StorageEngineFailureException(errorMsg, e);
      } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
        throw new StorageEngineFailureException(errorMsg, e);
      }
    }
  }
flush command Sync asyncCloseOneProcessor all file node processors.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java