[GitHub] [flink] pnowojski commented on a change in pull request #13562: [FLINK-18662][metrics][checkpointing] Provide processed/persisted bytes metrics and update alignment time metric.

[GitBox]

pnowojski commented on a change in pull request #13562:
URL: https://github.com/apache/flink/pull/13562#discussion_r501845717



##########
File path: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
##########
@@ -76,7 +76,7 @@
 
        private final CachingCheckpointStorageWorkerView checkpointStorage;
        private final String taskName;
-       private final ExecutorService executorService;

Review comment:
       Hmmm, I was referring to `AsyncCheckpointRunnable`. I will rename it 
maybe to `asyncOperationsThreadPool` to make it compliant with the 
`org.apache.flink.streaming.runtime.tasks.StreamTask#asyncOperationsThreadPool` 




----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org