Repository: flink Updated Branches: refs/heads/master de6a3d33e -> 234646844
[FLINK-4214] [web dashboard] Properly increment the exceptions counter This closes #2242 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/91d5c63a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/91d5c63a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/91d5c63a Branch: refs/heads/master Commit: 91d5c63a717d8786506c2d791bb4683838f699d8 Parents: de6a3d3 Author: Sumit Chawla <[email protected]> Authored: Wed Jul 13 12:16:01 2016 -0700 Committer: Stephan Ewen <[email protected]> Committed: Thu Jul 14 21:38:04 2016 +0200 ---------------------------------------------------------------------- .../flink/runtime/webmonitor/handlers/JobExceptionsHandler.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/91d5c63a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JobExceptionsHandler.java ---------------------------------------------------------------------- diff --git a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JobExceptionsHandler.java b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JobExceptionsHandler.java index 0d71dcb..7b6a361 100644 --- a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JobExceptionsHandler.java +++ b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JobExceptionsHandler.java @@ -75,6 +75,7 @@ public class JobExceptionsHandler extends AbstractExecutionGraphRequestHandler { gen.writeStringField("task", task.getSimpleName()); gen.writeStringField("location", locationString); gen.writeEndObject(); + numExceptionsSoFar++; } } gen.writeEndArray();
