[flink] 05/08: [FLINK-17869][task][checkpointing] Increase ChannelStateWriterImpl.DEFAULT_MAX_CHECKPOINTS

[zhijiang]

This is an automated email from the ASF dual-hosted git repository.

zhijiang pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git

commit e14958dcd09f7c32ba2ba25fc6a48696fe7eeca2
Author: Roman Khachatryan <khachatryan.ro...@gmail.com>
AuthorDate: Wed Jun 3 15:56:47 2020 +0200

    [FLINK-17869][task][checkpointing] Increase 
ChannelStateWriterImpl.DEFAULT_MAX_CHECKPOINTS
    
    ChannelStateWriter map is cleaned up by the task thread,
    so the check in netty thread should take possible delay
    into account.
---
 .../apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java
index 3e18050..89a5247 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java
@@ -56,7 +56,7 @@ import static 
org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteReque
 public class ChannelStateWriterImpl implements ChannelStateWriter {
 
        private static final Logger LOG = 
LoggerFactory.getLogger(ChannelStateWriterImpl.class);
-       private static final int DEFAULT_MAX_CHECKPOINTS = 5; // currently, 
only single in-flight checkpoint is supported
+       private static final int DEFAULT_MAX_CHECKPOINTS = 1000; // includes 
max-concurrent-checkpoints + checkpoints to be aborted (scheduled via mailbox)
 
        private final String taskName;
        private final ChannelStateWriteRequestExecutor executor;