Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6035
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6035#discussion_r189019837
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -947,6 +964,36 @@ private void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6035#discussion_r189019783
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -1605,9 +1609,16 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6035#discussion_r189017088
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -947,6 +964,36 @@ private void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6035#discussion_r189016636
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerConfiguration.java
---
@@ -50,8 +50,11 @@
private final
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6035#discussion_r189016685
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -1605,9 +1609,16 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6035#discussion_r189016603
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -232,8 +239,10 @@ public TaskExecutor(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/6035#discussion_r189004536
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -1605,9 +1609,16 @@ public void notifyHeartbeatTimeout(final
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/6035#discussion_r189012246
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -947,6 +964,36 @@ private void
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/6035#discussion_r189013436
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -947,6 +964,36 @@ private void
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/6035#discussion_r188992099
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -232,8 +239,10 @@ public TaskExecutor(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/6035#discussion_r189004280
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerConfiguration.java
---
@@ -50,8 +50,11 @@
private final String[]
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/6035
[FLINK-6160] Add reconnection attempts in case of heartbeat timeouts to
JobMaster and TaskExecutor
## What is the purpose of the change
If a timeout with the RM occurs on on the
13 matches
Mail list logo
