Micronaut Cosmos DB Serde encoding / serializer error with nested Map

[kevin-titantech]

When using @CosmosRepository which extends CrudRepository, with an @MappedEntity that contains a nested map, I'm running into an encoding error in the MN JsonNodeEncoder when saving the data via CrudRepository save method.

20:38:40.129 [io-executor-thread-1] ERROR i.m.http.server.RouteExecutor - Unexpected error occurred: Already have a key
java.lang.IllegalStateException: Already have a key
        at io.micronaut.serde.support.util.JsonNodeEncoder$Obj.encodeKey(JsonNodeEncoder.java:176)
        at io.micronaut.serde.support.serializers.CustomizedMapSerializer.encodeMapKey(CustomizedMapSerializer.java:121)
        at io.micronaut.serde.support.serializers.CustomizedMapSerializer$2.serializeInto(CustomizedMapSerializer.java:92)        
        at io.micronaut.serde.support.serializers.CustomizedMapSerializer$2.serialize(CustomizedMapSerializer.java:85)
        at io.micronaut.serde.support.serializers.CustomizedMapSerializer$2.serialize(CustomizedMapSerializer.java:79)
        at io.micronaut.serde.support.serializers.CustomizedObjectSerializer.serializeIntoInternal(CustomizedObjectSerializer.java:157)
        at io.micronaut.serde.support.serializers.CustomizedObjectSerializer.serialize(CustomizedObjectSerializer.java:58)        
        at io.micronaut.data.cosmos.operations.CosmosSerde.serialize(CosmosSerde.java:104)
        at io.micronaut.data.cosmos.operations.CosmosSerde.serialize(CosmosSerde.java:69) 

The controller receives the following payload and deserializes into the MappedEntity POJO just fine. Creating a nested Map for "data".

{
	"datakey": "test",
	"compid": "gened-meaningful-id",
	"enrichid": "RFI-Requirement-Extraction",
	"txnid": "123",
	"source": "fileinfo",
	"data": {
		"filename": "31May2023_NCUA Virtual Exam NLP RFI.pdf",
		"fileid": "a0c71cc3-03b2-4411-aa36-d4f37c445079"
	},
	"createdDate": "2024-02-07T19:32:05.836Z",
	"updatedDate": "2024-02-07T19:32:05.836Z"
}

@MappedEntity
public class SkillOutput {
  @Id @GeneratedValue @PartitionKey private String id;
  @NonNull private String datakey;
  @NonNull private String compid;
  @NonNull private String enrichid;
  @NonNull private String txnid;
  @NonNull private String source;
  @NonNull private Map data;
  @DateCreated private Date createdDate;
  @DateUpdated private Date updatedDate;

  public SkillOutput(
      String id,
      ...
  )
  ... usual setters/getters
}

Excerpt from the Controller...

  @Post
  @Status(HttpStatus.CREATED)
  SkillOutput save(@Body SkillOutput entity) {
    return skillRepo.save(entity);
  }

But when CosmosSerde attempts to serialize the MappedEntity POJO, once the serializer finds the nested "data Map", it seems like it doesn't understand it's working on a nested MAP and throws the above exception.

Has anyone else experienced this problem and/or saved a nested map? In my case, I don't know what the data Map will contain. In MN terms I supposed it would be considered "arbitrary", but that is by design.

All inputs/comments/observations welcome. Thanks in advance.

[radovanradic]

Which micronaut-data version are you using? Can you switch to the latest?
There was a bug in micronaut-serialization micronaut-projects/micronaut-serialization#734 that has been fixed in micronaut-serialization 2.7.1 that should resolve this issue.
So, please try using latest micronaut-data version and/or micronaut-serialization 2.7.1 or later.

[kevin-titantech]

Hi Radovan - Thanks for the response and suggestion. Updating did indeed fix the issue.