hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ga...@apache.org
Subject svn commit: r1643874 - /hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java
Date Mon, 08 Dec 2014 18:12:02 GMT
Author: gates
Date: Mon Dec  8 18:12:01 2014
New Revision: 1643874

URL: http://svn.apache.org/r1643874
Log:
HIVE-8880 non-synchronized access to split list in OrcInputFormat (Alan Gates, reviewed by
Owen O'Malley)

Modified:
    hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java

Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java?rev=1643874&r1=1643873&r2=1643874&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java Mon Dec  8
18:12:01 2014
@@ -559,8 +559,10 @@ public class OrcInputFormat  implements
         if (!deltas.isEmpty()) {
           for (int b = 0; b < context.numBuckets; ++b) {
             if (!covered[b]) {
-              context.splits.add(new OrcSplit(dir, b, 0, new String[0], null,
-                  false, false, deltas));
+              synchronized (context.splits) {
+                context.splits.add(new OrcSplit(dir, b, 0, new String[0], null,
+                    false, false, deltas));
+              }
             }
           }
         }



Mime
View raw message