You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2015/02/11 15:17:15 UTC
flink git commit: [runtime] Corrects messages sent to the JobManager
by the JobManagerInfoServlet
Repository: flink
Updated Branches:
refs/heads/master 1e9b68164 -> bec9c4dae
[runtime] Corrects messages sent to the JobManager by the JobManagerInfoServlet
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bec9c4da
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bec9c4da
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/bec9c4da
Branch: refs/heads/master
Commit: bec9c4dae79928f55bcc3de3c6f5d5417f9b5608
Parents: 1e9b681
Author: Till Rohrmann <tr...@apache.org>
Authored: Wed Feb 11 15:16:28 2015 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Wed Feb 11 15:16:28 2015 +0100
----------------------------------------------------------------------
.../apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/bec9c4da/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.java
index 6de3b39..bf2ef70 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/web/JobManagerInfoServlet.java
@@ -420,7 +420,7 @@ public class JobManagerInfoServlet extends HttpServlet {
try {
Iterable<ExecutionGraph> graphs = AkkaUtils.<RunningJobs>ask(jobmanager,
- ArchiveMessages.getRequestArchivedJobs(), timeout).asJavaIterable();
+ JobManagerMessages.getRequestRunningJobs(), timeout).asJavaIterable();
//Serialize job to json
wrt.write("{");