diff --git a/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AuthPoliciesBootstrapper.java b/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AuthPoliciesBootstrapper.java index 64b8df815c..310f9720e8 100644 --- a/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AuthPoliciesBootstrapper.java +++ b/repository/src/main/java/org/apache/atlas/repository/store/bootstrap/AuthPoliciesBootstrapper.java @@ -105,7 +105,7 @@ private void loadPoliciesInFolder (File folder) { String policiesDirName = folder.getName(); File[] policyFiles = folder.exists() ? folder.listFiles() : null; - List fileList= new ArrayList<>(0); + // List fileList= new ArrayList<>(0); if (ArrayUtils.isNotEmpty(policyFiles)) { @@ -115,17 +115,17 @@ private void loadPoliciesInFolder (File folder) { if (!item.isFile()) { loadPoliciesInFolder(item); } else { - //loadPoliciesInFile(item); - fileList.add(item); + loadPoliciesInFile(item); + //fileList.add(item); } } // loadPoliciesInFile in async - List> futures = fileList.stream() - .map(file -> CompletableFuture.runAsync(() -> loadPoliciesInFile(file))) - .collect(Collectors.toList()); - - CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join(); +// List> futures = fileList.stream() +// .map(file -> CompletableFuture.runAsync(() -> loadPoliciesInFile(file))) +// .collect(Collectors.toList()); +// +// CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join(); } else { LOG.warn("No policies for Bootstrapping in directory {}..", policiesDirName); }