Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5893
i saw legacy/SubtasksAllAccumulatorsHandler.java used
gen.writeStringField("id", jobVertex.getJobVertexId().toString());.
if i change the type of `SubtasksAllAccumulatorsInfo#jobVertexId` to
`JobVertexID` ,
run the `SubtasksAllAccumulatorsInfoTest` will fail, error log as follow:
>
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException:
Unrecognized field "bytes" (class
org.apache.flink.runtime.jobgraph.JobVertexID), not marked as ignorable (2
known properties: "lowerPart", "upperPart"])
at [Source:
{"id":{"upperPart":-7327168959427448358,"lowerPart":4189391734336269051,"bytes":"OiO1lgYSKvuaUKqnBA7x2g=="},"parallelism":4,"subtasks":[{"subtask":0,"attempt":0,"host":"host-0","user-accumulators":[{"name":"test
name1","type":"test type1","value":"test value1"},{"name":"test
name2","type":"test type2","value":"test
value2"}]},{"subtask":1,"attempt":1,"host":"host-1","user-accumulators":[{"name":"test
name1","type":"test type1","value":"test value1"},{"name":"test
name2","type":"test type2","value":"test
value2"}]},{"subtask":2,"attempt":2,"host":"host-2","user-accumulators":[{"name":"test
name1","type":"test type1","value":"test value1"},{"name":"test
name2","type":"test type2","value":"test value2"}]}]}; line: 1, column: 82]
(through reference chain:
org.apache.flink.runtime.rest.messages.job.SubtasksAllAccumulatorsInfo["id"]->org.apache.flink.runtime.jobgraph.JobVertexID["bytes"])
---
