Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5872
---
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5872#discussion_r182478661
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -857,7 +859,7 @@ public void run() {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5872#discussion_r182461066
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -857,7 +859,7 @@ public void run() {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5872#discussion_r182459949
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -1214,7 +1216,7 @@ public void run() {
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5872#discussion_r182455513
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -857,7 +859,7 @@ public void run() {
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5872#discussion_r182455202
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -1214,7 +1216,7 @@ public void run() {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5872#discussion_r182441934
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -1214,7 +1216,7 @@ public void run() {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5872#discussion_r182442219
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -857,7 +859,7 @@ public void run() {
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5872
[FLINK-9206][checkpoints] add job IDs to CheckpointCoordinator log messages
## What is the purpose of the change
The `CheckpointCoordinator` exists per job but its log messages (all
bundled
