Merge pull request #136 from baharclerode/bah.AvroUnionMapValues

[Avro] Fix MapWriteContext not correctly resolving union values

Author: cowtowncoder

avro/src/main/java/com/fasterxml/jackson/dataformat/avro/ser/MapWriteContext.java

@@ -52,6 +52,14 @@ public final AvroWriteContext createChildObjectContext() throws JsonMappingExcep
         return child;
     }
 
+    @Override
+    public final AvroWriteContext createChildObjectContext(Object currValue) throws JsonMappingException {
+        _verifyValueWrite();
+        AvroWriteContext child = _createObjectContext(_schema.getValueType(), currValue);
+        _data.put(_currentName, child.rawValue());
+        return child;
+    }
+
     @Override
     public void writeValue(Object value) {
         _verifyValueWrite();

avro/src/test/java/com/fasterxml/jackson/dataformat/avro/interop/annotations/UnionTest.java

@@ -2,7 +2,9 @@
 
 import java.io.IOException;
 import java.util.Arrays;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 import org.apache.avro.UnresolvedUnionException;
 import org.apache.avro.reflect.Nullable;
@@ -87,17 +89,21 @@ public boolean equals(Object o) {
     public static class PetShop {
         public List<Animal> pets;
 
+        public Map<String, Animal> specialPets;
+
         protected PetShop() { }
         public PetShop(Animal... p) {
             pets = Arrays.asList(p);
+            specialPets = new HashMap<>();
         }
 
         @Override
         public boolean equals(Object o) {
             if (o.getClass() == getClass()) {
                 PetShop other = (PetShop) o;
                 if (pets == null) return other.pets == null;
-                else return pets.equals(other.pets);
+                if (specialPets == null) return other.specialPets == null;
+                else return pets.equals(other.pets) && specialPets.equals(other.specialPets);
             }
             return false;
         }
@@ -142,4 +148,15 @@ public void testListWithInterfaceUnion() throws IOException {
         assertThat(result).isEqualTo(shop);
     }
 
+    @Test
+    public void testMapWithInterfaceUnion() throws IOException {
+        PetShop shop = new PetShop(new Cat("tabby"), new Dog(4), new Dog(5), new Cat("calico"));
+        shop.specialPets.put("pet1", new Cat("siamese"));
+        shop.specialPets.put("pet2", new Dog(6));
+        //
+        PetShop result = roundTrip(shop);
+        //
+        assertThat(result).isEqualTo(shop);
+    }
+
 }