commit | 0e8c6833b398033da017f04caaff277143919b22 | [log] [tgz] |
---|---|---|
author | vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> | Fri Jan 07 08:19:59 2011 +0000 |
committer | vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> | Fri Jan 07 08:19:59 2011 +0000 |
tree | f394266af8a0c77a554677fa32ddc6de39d5faed | |
parent | c84197b87ac38732cd3f26b35bb05216f1581ce1 [diff] |
Merged r294 from the hyracks_io_management branch git-svn-id: https://hyracks.googlecode.com/svn/trunk@295 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks/hyracks-api/src/main/java/edu/uci/ics/hyracks/api/io/FileHandle.java b/hyracks/hyracks-api/src/main/java/edu/uci/ics/hyracks/api/io/FileHandle.java index e0e7681..31e9821 100644 --- a/hyracks/hyracks-api/src/main/java/edu/uci/ics/hyracks/api/io/FileHandle.java +++ b/hyracks/hyracks-api/src/main/java/edu/uci/ics/hyracks/api/io/FileHandle.java
@@ -37,6 +37,7 @@ break; case READ_WRITE: + fileRef.getFile().getAbsoluteFile().getParentFile().mkdirs(); switch (syncMode) { case METADATA_ASYNC_DATA_ASYNC: mode = "rw";
diff --git a/hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/io/IOManager.java b/hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/io/IOManager.java index 57174b5..2275d00 100644 --- a/hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/io/IOManager.java +++ b/hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/io/IOManager.java
@@ -45,6 +45,7 @@ workAreaIODevices = new ArrayList<IODeviceHandle>(); for (IODeviceHandle d : ioDevices) { if (d.getWorkAreaPath() != null) { + new File(d.getPath(), d.getWorkAreaPath()).mkdirs(); workAreaIODevices.add(d); } }