pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From roh...@apache.org
Subject svn commit: r1739792 - in /pig/trunk: CHANGES.txt src/org/apache/pig/builtin/OrcStorage.java
Date Mon, 18 Apr 2016 17:09:05 GMT
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 +



Mime
View raw message