You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2016/07/14 20:33:12 UTC
[1/2] flink git commit: [FLINK-4214] [web dashboard] Properly
increment the exceptions counter
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 <su...@gmail.com>
Authored: Wed Jul 13 12:16:01 2016 -0700
Committer: Stephan Ewen <se...@apache.org>
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();
[2/2] flink git commit: [FLINK-4216] [docs] Fixed example.
Posted by se...@apache.org.
[FLINK-4216] [docs] Fixed example.
This closes #2246
This closes #2247
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/23464684
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/23464684
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/23464684
Branch: refs/heads/master
Commit: 2346468446414b2a14c2833be4d60288cd8d0550
Parents: 91d5c63
Author: mjsax <mj...@apache.org>
Authored: Thu Jul 14 11:24:28 2016 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Thu Jul 14 21:42:41 2016 +0200
----------------------------------------------------------------------
docs/apis/common/index.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/23464684/docs/apis/common/index.md
----------------------------------------------------------------------
diff --git a/docs/apis/common/index.md b/docs/apis/common/index.md
index 559d509..ea7c0af 100644
--- a/docs/apis/common/index.md
+++ b/docs/apis/common/index.md
@@ -840,7 +840,7 @@ public class WordWithCount {
}
}
-DataStream<Tuple2<String, Integer>> wordCounts = env.fromElements(
+DataStream<WordWithCount> wordCounts = env.fromElements(
new WordWithCount("hello", 1),
new WordWithCount("world", 2));
@@ -1349,4 +1349,4 @@ that you have set `jobmanager.web.submit.enable: true` in `flink-conf.yaml`.
You may specify program arguments before the job is executed. The plan visualization enables you to show
the execution plan before executing the Flink job.
-{% top %}
\ No newline at end of file
+{% top %}