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 2023/03/30 17:30:29 UTC

svn commit: r1908806 - in /pig/branches/branch-0.18: CHANGES.txt src/org/apache/pig/impl/util/Utils.java

Author: rohini
Date: Thu Mar 30 17:30:28 2023
New Revision: 1908806

URL: http://svn.apache.org/viewvc?rev=1908806&view=rev
Log:
PIG-5432: OrcStorage fails to detect schema in some cases (jtolar via rohini)

Modified:
    pig/branches/branch-0.18/CHANGES.txt
    pig/branches/branch-0.18/src/org/apache/pig/impl/util/Utils.java

Modified: pig/branches/branch-0.18/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.18/CHANGES.txt?rev=1908806&r1=1908805&r2=1908806&view=diff
==============================================================================
--- pig/branches/branch-0.18/CHANGES.txt (original)
+++ pig/branches/branch-0.18/CHANGES.txt Thu Mar 30 17:30:28 2023
@@ -122,6 +122,8 @@ OPTIMIZATIONS
  
 BUG FIXES
 
+PIG-5432: OrcStorage fails to detect schema in some cases (jtolar via rohini)
+
 PIG-5439: pig.exec.reducers.max does not take effect for skewed join (vnarayanan7 via rohini)
 
 PIG-5431: Date datatype is different between Hive 1.x and Hive 3.x (rohini)

Modified: pig/branches/branch-0.18/src/org/apache/pig/impl/util/Utils.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.18/src/org/apache/pig/impl/util/Utils.java?rev=1908806&r1=1908805&r2=1908806&view=diff
==============================================================================
--- pig/branches/branch-0.18/src/org/apache/pig/impl/util/Utils.java (original)
+++ pig/branches/branch-0.18/src/org/apache/pig/impl/util/Utils.java Thu Mar 30 17:30:28 2023
@@ -655,9 +655,14 @@ public class Utils {
                   continue;
               }
             } else {
-              return depthFirstSearchForFile(
+              Path result = depthFirstSearchForFile(
                   fileSystem.listStatus(f.getPath(), VISIBLE_FILES),
                   fileSystem, filter);
+
+              // return the first found result, else continue searching through statusArray
+              if (result != null) {
+                  return result;
+              }
             }
       }