HIVE-10619 Fix ConcurrentHashMap.get in MetadataListStructObjectInspector.getInstance (52) (Alexander Pivovarov, reviewed by Szehon Ho)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/03eca770 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/03eca770 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/03eca770 Branch: refs/heads/parquet Commit: 03eca7708ef2b1d9bdf3a4265639dd3d5541ca74 Parents: b09fcfb Author: Alexander Pivovarov <[email protected]> Authored: Tue May 5 20:57:42 2015 -0700 Committer: Alexander Pivovarov <[email protected]> Committed: Wed May 13 13:13:33 2015 -0700 ---------------------------------------------------------------------- .../serde2/objectinspector/MetadataListStructObjectInspector.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/03eca770/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/MetadataListStructObjectInspector.java ---------------------------------------------------------------------- diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/MetadataListStructObjectInspector.java b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/MetadataListStructObjectInspector.java index e68325f..5a2beb9 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/MetadataListStructObjectInspector.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/objectinspector/MetadataListStructObjectInspector.java @@ -49,7 +49,7 @@ public class MetadataListStructObjectInspector extends List<String> columnNames) { ArrayList<List<String>> key = new ArrayList<List<String>>(1); key.add(columnNames); - MetadataListStructObjectInspector result = cached.get(columnNames); + MetadataListStructObjectInspector result = cached.get(key); if (result == null) { result = new MetadataListStructObjectInspector(columnNames); MetadataListStructObjectInspector prev = cached.putIfAbsent(key, result);
