Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5093#discussion_r153524341
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/ResourceIDSerializer.java
---
@@ -29,16 +30,16 @@
/**
* Json serializer for {@link InstanceID}.
*/
-public class InstanceIDSerializer extends StdSerializer<InstanceID> {
+public class ResourceIDSerializer extends StdSerializer<ResourceID> {
private static final long serialVersionUID = 5798852092159615938L;
- protected InstanceIDSerializer() {
- super(InstanceID.class);
+ protected ResourceIDSerializer() {
+ super(ResourceID.class);
}
@Override
- public void serialize(InstanceID value, JsonGenerator gen,
SerializerProvider provider) throws IOException {
+ public void serialize(ResourceID value, JsonGenerator gen,
SerializerProvider provider) throws IOException {
gen.writeString(value.toString());
--- End diff --
Good point. Fixed with your commit.
---
