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
16 matches
Mail list logo