You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ro...@apache.org on 2016/04/18 19:09:05 UTC

svn commit: r1739792 - in /pig/trunk: CHANGES.txt src/org/apache/pig/builtin/OrcStorage.java

Author: rohini
Date: Mon Apr 18 17:09:05 2016
New Revision: 1739792

URL: http://svn.apache.org/viewvc?rev=1739792&view=rev
Log:
PIG-4860: Loading data using OrcStorage() accepts only default FileSystem path (beriaanirudh via rohini)

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/src/org/apache/pig/builtin/OrcStorage.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1739792&r1=1739791&r2=1739792&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Mon Apr 18 17:09:05 2016
@@ -113,6 +113,8 @@ PIG-4639: Add better parser for Apache H
 
 BUG FIXES
 
+PIG-4860: Loading data using OrcStorage() accepts only default FileSystem path (beriaanirudh via rohini)
+
 PIG-4868: Low values for bytes.per.reducer configured by user not honored in Tez for inputs (rohini)
 
 PIG-4869: Removing unwanted configuration in Tez broke ConfiguredFailoverProxyProvider (rohini)

Modified: pig/trunk/src/org/apache/pig/builtin/OrcStorage.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/builtin/OrcStorage.java?rev=1739792&r1=1739791&r2=1739792&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/builtin/OrcStorage.java (original)
+++ pig/trunk/src/org/apache/pig/builtin/OrcStorage.java Mon Apr 18 17:09:05 2016
@@ -456,7 +456,7 @@ public class OrcStorage extends LoadFunc
     }
 
     private TypeInfo getTypeInfoFromLocation(String location, Job job) throws IOException {
-        FileSystem fs = FileSystem.get(job.getConfiguration());
+        FileSystem fs = FileSystem.get(new Path(location).toUri(), job.getConfiguration());
         Path path = getFirstFile(location, fs, new NonEmptyOrcFileFilter(fs));
         if (path == null) {
             log.info("Cannot find any ORC files from " + location +