Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5893
I'll address the remaining issues myself when merging, thanks for working
on this!
---
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5893
@zentol thanks you. I updated the code. :laughing:
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5893
see `JobVertexDetailsInfo` on how to use it.
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5893
You have to use the `JobVertexIDSerializer` for that field.
---
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
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5893
You have not changed the type of `SubtasksAllAccumulatorsInfo#jobVertexId`
to `JobVertexID`.
---
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5893
@zentol thanks for your review. I have updated the PR.
---
