HDFS

提交Job

所有依赖上传应用暂存目录/user/${linux_user_name}/.flink/${application_id}。应用结束会删掉此目录。
依赖分三类：conf、lib、plugins。

  1. conf目录下三个文件：flink-conf.yaml、logback.xml、log4j.properties。
  2. lib目录下所有文件：flink-dist_2.11-1.9.0.jar、flink-table_2.11-1.9.0.jar、slf4j-log4j12-1.7.15.jar等。
  3. plugins目录下所有文件：README.txt等。
  4. JobGraph：Per-Job模式才有。

Blob Service

HA

路径头部：${high-availability.storageDir}
${high-availability.storageDir}/${application_id}/blob

JobGraphStore

Checkpoint

路径头部：${state.checkpoints.dir}

  1. /${state.checkpoints.dir}/${job_id}
  2. /${state.checkpoints.dir}/${job_id}/shared
  3. /${state.checkpoints.dir}/${job_id}/taskowned
  5. /${state.checkpoints.dir}/${job_id}/chk-${checkpoint_id}
  6. /${state.checkpoints.dir}/${job_id}/chk-${checkpoint_id}/_metadata
  7. /${state.checkpoints.dir}/${job_id}/chk-${checkpoint_id}/${random.UUID}

ZooKeeper

HA

元数据存储

JobGraph路径

选举

/flink/${application_id}/leaderlatch/${job_id}/resource_manager_lock
/flink/${application_id}/leader/${job_id}/resource_manager_lock
resource_manager、job_manager、rest_server、dispatcher。