diff --git serde/src/java/org/apache/hadoop/hive/serde2/avro/InstanceCache.java serde/src/java/org/apache/hadoop/hive/serde2/avro/InstanceCache.java index 09fca68..2d52020 100644 --- serde/src/java/org/apache/hadoop/hive/serde2/avro/InstanceCache.java +++ serde/src/java/org/apache/hadoop/hive/serde2/avro/InstanceCache.java @@ -51,7 +51,7 @@ public Instance retrieve(SeedObject hv) throws AvroSerdeException { * Retrieve (or create if it doesn't exist) the correct Instance for this * SeedObject using 'seenSchemas' to resolve circular references */ - public Instance retrieve(SeedObject hv, + public synchronized Instance retrieve(SeedObject hv, Set seenSchemas) throws AvroSerdeException { if(LOG.isDebugEnabled()) LOG.debug("Checking for hv: " + hv.toString());