Merge branch 'hotfix/UV_Core_v2.0.4'

UnifiedViews · Jun 30, 2015 · 98d84eb · 98d84eb
2 parents 25453df + c620e03
commit 98d84eb
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 7 deletions.
diff --git a/backend/src/main/java/cz/cuni/mff/xrg/odcs/backend/execution/pipeline/impl/CleanUp.java b/backend/src/main/java/cz/cuni/mff/xrg/odcs/backend/execution/pipeline/impl/CleanUp.java
@@ -61,6 +61,13 @@ public boolean postAction(PipelineExecution execution,
             Map<Node, Context> contexts,
             DependencyGraph graph) {
         LOG.debug("CleanUp start .. ");
+
+        try {
+            this.relationalRepositoryManager.release(execution.getContext().getExecutionId());
+        } catch (Exception e) {
+            LOG.error("Failed to release relational repository", e);
+        }
+
         // first release contexts
         for (Context item : contexts.values()) {
             if (execution.isDebugging()) {
@@ -93,12 +100,6 @@ public boolean postAction(PipelineExecution execution,
             }
         }
 
-        try {
-            this.relationalRepositoryManager.release(execution.getContext().getExecutionId());
-        } catch (Exception e) {
-            LOG.error("Failed to release relational repository", e);
-        }
-
         // prepare execution root
         File rootDir = new File(
                 appConfig.getString(ConfigProperty.GENERAL_WORKINGDIR));

diff --git a/...src/main/java/eu/unifiedviews/dataunit/relational/repository/FilesRelationalDatabase.java b/...src/main/java/eu/unifiedviews/dataunit/relational/repository/FilesRelationalDatabase.java
@@ -127,12 +127,17 @@ public void release() throws Exception {
 
     private void deleteDatabaseFile() throws IOException {
         Pattern filesPattern = Pattern.compile(this.databaseFileName + ".*");
+        if (this.dataunitDirectory == null || !this.dataunitDirectory.exists()) {
+            return;
+        }
         File[] filesInDataUnitDir = this.dataunitDirectory.listFiles();
+        if (filesInDataUnitDir == null) {
+            return;
+        }
         for (File file : filesInDataUnitDir) {
             if (filesPattern.matcher(file.getName()).matches()) {
                 Files.delete(file.toPath());
             }
-            break;
         }
     }