[
https://issues.apache.org/jira/browse/FLINK-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448042#comment-16448042
]
ASF GitHub Bot commented on FLINK-9212:
---------------------------------------
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"])
> Port SubtasksAllAccumulatorsHandler to new REST endpoint
> --------------------------------------------------------
>
> Key: FLINK-9212
> URL: https://issues.apache.org/jira/browse/FLINK-9212
> Project: Flink
> Issue Type: Sub-task
> Components: REST
> Affects Versions: 1.5.0
> Reporter: Chesnay Schepler
> Assignee: Hai Zhou
> Priority: Blocker
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
