private static Map<String, ContainerModel> deserializeContainerModelMap(
      String serializedContainerModel) {
    Map<String, ContainerModel> containerModelMap = null;
    ObjectMapper samzaObjectMapper = SamzaObjectMapper.getObjectMapper();

    try {
      if (serializedContainerModel != null) {
        containerModelMap = samzaObjectMapper.readValue(serializedContainerModel, new TypeReference<Map<String, ContainerModel>>() {
        });
      }
    } catch (IOException e) {
      LOG.error("Exception in deserializing container model ", e);
    }

    return containerModelMap;
  }
Helper method to use {@link SamzaObjectMapper} to deserialize {@link ContainerModel}s.
{@link SamzaObjectMapper} provides several conventions and optimizations for deserializing containerModels.
@return
samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java