flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject flink git commit: [runtime] Corrects messages sent to the JobManager by the JobManagerInfoServlet
Date Wed, 11 Feb 2015 14:17:15 GMT
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 <trohrmann@apache.org>
Authored: Wed Feb 11 15:16:28 2015 +0100
Committer: Till Rohrmann <trohrmann@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("{");


Mime
View raw message