diff --git a/spring-boot-starter-mesos/src/main/java/com/containersolutions/mesos/scheduler/state/StateRepositoryZookeeper.java b/spring-boot-starter-mesos/src/main/java/com/containersolutions/mesos/scheduler/state/StateRepositoryZookeeper.java index 54156fa..c338550 100644 --- a/spring-boot-starter-mesos/src/main/java/com/containersolutions/mesos/scheduler/state/StateRepositoryZookeeper.java +++ b/spring-boot-starter-mesos/src/main/java/com/containersolutions/mesos/scheduler/state/StateRepositoryZookeeper.java @@ -42,14 +42,14 @@ public Optional getFrameworkID() { if (value.length == 0) { return Optional.empty(); } - return Optional.of(Protos.FrameworkID.newBuilder().setValue(new String(value)).build()); + return Optional.of(Protos.FrameworkID.newBuilder().setValue(((String) SerializationUtils.deserialize(value))).build()); } @EventListener public void onFrameworkRegistered(FrameworkRegistreredEvent event) { logger.debug("Received frameworkId=" + event.getFrameworkID().getValue()); frameworkId.set(event.getFrameworkID()); - set("frameworkid", frameworkId.get()); + set("frameworkid", frameworkId.get().getValue()); } @EventListener