Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5184
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160692953
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -956,23 +958,29 @@ private void jobStatusChanged(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160692288
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -357,6 +360,31 @@ public void start() throws
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160453714
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -357,6 +360,31 @@ public void start() throws Exception {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160408755
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobExecutionResult.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the Apache
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160408734
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobExecutionResult.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the Apache
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160407686
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -956,23 +958,29 @@ private void jobStatusChanged(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160114353
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobExecutionResultCache.java
---
@@ -0,0 +1,91 @@
+/*
+ * Licensed
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160110253
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobExecutionResult.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160108453
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java
---
@@ -358,12 +360,12 @@ private
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160107760
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -956,23 +958,29 @@ private void jobStatusChanged(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160105159
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobExecutionResultCache.java
---
@@ -0,0 +1,91 @@
+/*
+ * Licensed
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r159603034
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -357,6 +360,31 @@ public void start() throws
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160110770
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobExecutionResult.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160108633
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java
---
@@ -405,22 +407,27 @@ private void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160105972
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobExecutionResult.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160106268
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -936,17 +936,19 @@ private void jobStatusChanged(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r160111827
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java
---
@@ -458,7 +465,14 @@ public
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r159826471
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -936,17 +936,19 @@ private void jobStatusChanged(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r157963387
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java
---
@@ -405,22 +407,27 @@ private void
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r157962431
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java
---
@@ -458,7 +465,14 @@ public JobExecutionResult
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r157878862
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java
---
@@ -358,12 +360,12 @@ private
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r157877969
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobExecutionResult.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the Apache
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r157877406
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java
---
@@ -458,7 +465,14 @@ public JobExecutionResult
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r157876761
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java
---
@@ -92,4 +94,42 @@
* @return Future containing the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r157876793
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java
---
@@ -92,4 +94,42 @@
* @return Future containing the
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5184
[FLINK-8234][flip6] Cache JobExecutionResult in Dispatcher
## What is the purpose of the change
Cache `JobExecutionResult` in `Dispatcher`, and add methods to
`RestfulGateway` to enable
27 matches
Mail list logo
