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:15:45 UTC
svn commit: r1643875 -
/hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java
Author: gates
Date: Mon Dec 8 18:15:44 2014
New Revision: 1643875
URL: http://svn.apache.org/r1643875
Log:
HIVE-8880 non-synchronized access to split list in OrcInputFormat (Alan Gates, reviewed by Owen O'Malley)
Modified:
hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java
Modified: hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java
URL: http://svn.apache.org/viewvc/hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java?rev=1643875&r1=1643874&r2=1643875&view=diff
==============================================================================
--- hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java (original)
+++ hive/branches/branch-0.14/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcInputFormat.java Mon Dec 8 18:15:44 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));
+ }
}
}
}