| commit | 59604752c0f8be7001fa11b519e4333cf2e7e2c9 | [log] [tgz] |
|---|---|---|
| author | ramangrover29@gmail.com <ramangrover29@gmail.com@eaa15691-b419-025a-1212-ee371bd00084> | Fri Apr 05 16:40:00 2013 +0000 |
| committer | ramangrover29@gmail.com <ramangrover29@gmail.com@eaa15691-b419-025a-1212-ee371bd00084> | Fri Apr 05 16:40:00 2013 +0000 |
| tree | 644230078db9585bbf022d058635eece519c2e2c | |
| parent | a159f9568e2a64ace4cd4fde9c0df8283edeb542 [diff] |
Fix for issue 315 git-svn-id: https://asterixdb.googlecode.com/svn/branches/asterix_lsm_stabilization_315@1517 eaa15691-b419-025a-1212-ee371bd00084
diff --git a/asterix-external-data/src/main/java/edu/uci/ics/asterix/external/dataset/adapter/NCFileSystemAdapter.java b/asterix-external-data/src/main/java/edu/uci/ics/asterix/external/dataset/adapter/NCFileSystemAdapter.java index ae9b412..ef39d45 100644 --- a/asterix-external-data/src/main/java/edu/uci/ics/asterix/external/dataset/adapter/NCFileSystemAdapter.java +++ b/asterix-external-data/src/main/java/edu/uci/ics/asterix/external/dataset/adapter/NCFileSystemAdapter.java
@@ -61,7 +61,7 @@ return AdapterType.READ; } - private void configureFileSplits(String[] splits) { + private void configureFileSplits(String[] splits) throws AsterixException { if (fileSplits == null) { fileSplits = new FileSplit[splits.length]; String nodeName; @@ -70,6 +70,10 @@ String trimmedValue; for (String splitPath : splits) { trimmedValue = splitPath.trim(); + if (!trimmedValue.contains("://")) { + throw new AsterixException("Invalid path: " + splitPath + + "\nUsage- path=\"Host://Absolute File Path\""); + } nodeName = trimmedValue.split(":")[0]; nodeLocalPath = trimmedValue.split("://")[1]; FileSplit fileSplit = new FileSplit(nodeName, new FileReference(new File(nodeLocalPath)));