You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ga...@apache.org on 2014/12/08 19:12:02 UTC
svn commit: r1643874 -
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java
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));
+ }
}
}
}