Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165835719
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -305,6 +311,84 @@ public void postStop() throws Exception
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165835514
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -305,6 +311,84 @@ public void postStop() throws Exception
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165835488
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -358,6 +361,18 @@ public void start() throws Exception {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165835486
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -313,6 +325,13 @@ public JobMaster(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165835482
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java
---
@@ -0,0 +1,184 @@
+/*
+ * Licensed to
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165835483
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -867,6 +889,25 @@ public void heartbeatFromResourceManager(final
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165835481
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -305,6 +311,84 @@ public void postStop() throws Exception
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165666773
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TestingTaskExecutorGateway.java
---
@@ -75,6 +76,17 @@ public void
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165298568
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -305,6 +311,84 @@ public void postStop() throws Exception
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165296204
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java
---
@@ -0,0 +1,184 @@
+/*
+ * Licensed to
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165296332
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -358,6 +361,18 @@ public void start() throws Exception {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165291604
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -313,6 +325,13 @@ public JobMaster(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165294395
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -305,6 +311,84 @@ public void postStop() throws
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165292444
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java
---
@@ -0,0 +1,184 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165291802
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -867,6 +889,25 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165290983
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -358,6 +361,18 @@ public void start() throws
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165155912
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/BackPressureStatsTracker.java
---
@@ -74,7 +74,7 @@
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165155639
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java
---
@@ -0,0 +1,184 @@
+/*
+ * Licensed to
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165155368
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TestingTaskExecutorGateway.java
---
@@ -75,6 +76,17 @@ public void
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5397
[FLINK-7856][flip6] WIP
WIP
PR is based on #4893
@tillrohrmann
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/GJL/flink
20 matches
Mail list logo
