Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5737#discussion_r176517725
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java
---
@@ -50,13 +51,13 @@
@JsonProperty(FIELD_NAME_SERIALIZED_USER_TASK_ACCUMULATORS)
@JsonSerialize(contentUsing = SerializedValueSerializer.class)
- private Map<String, SerializedValue<Object>> serializedUserAccumulators;
+ private Map<String, SerializedValue<OptionalFailure<Object>>>
serializedUserAccumulators;
@JsonCreator
public JobAccumulatorsInfo(
- @JsonProperty(FIELD_NAME_JOB_ACCUMULATORS)
List<JobAccumulator> jobAccumulators,
- @JsonProperty(FIELD_NAME_USER_TASK_ACCUMULATORS)
List<UserTaskAccumulator> userAccumulators,
- @JsonDeserialize(contentUsing =
SerializedValueDeserializer.class)
@JsonProperty(FIELD_NAME_SERIALIZED_USER_TASK_ACCUMULATORS) Map<String,
SerializedValue<Object>> serializedUserAccumulators) {
+ @JsonProperty(FIELD_NAME_JOB_ACCUMULATORS) List<JobAccumulator>
jobAccumulators,
+ @JsonProperty(FIELD_NAME_USER_TASK_ACCUMULATORS)
List<UserTaskAccumulator> userAccumulators,
+ @JsonDeserialize(contentUsing =
SerializedValueDeserializer.class)
@JsonProperty(FIELD_NAME_SERIALIZED_USER_TASK_ACCUMULATORS) Map<String,
SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators) {
--- End diff --
indentation is wrong
---
