flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yew1eb <...@git.apache.org>
Subject [GitHub] flink issue #5893: [FLINK-9212][flip6] Port SubtasksAllAccumulatorsHandler t...
Date Mon, 23 Apr 2018 12:17:16 GMT
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"])



---

Mime
View raw message