Yun Tang created FLINK-11696:
--------------------------------
Summary: [checkpoint] Avoid to send mkdir requests to DFS from
task side
Key: FLINK-11696
URL: https://issues.apache.org/jira/browse/FLINK-11696
Project: Flink
Issue Type: Improvement
Components: State Backends, Checkpointing
Reporter: Yun Tang
Assignee: Yun Tang
Currently, when we create checkpoint directory in the distributed file system.
Not only {{CheckpointCoordinator}} but also {{FsCheckpointStorage}} in
{{StreamTask}} would create the {{checkpointsDirectory}},
{{sharedStateDirectory}} and {{taskOwnedStateDirectory}}. These many {{mkdir}}
RPC requests would cause a very high pressure on the distributed file system,
especially when the parallelism is large or jobs continue to failover again and
again.
We could avoid these {{mkdir}} requests from task side if writing to a
distributed file system.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)