问：flink docker

Question

当我在JobManager中提交作业时，我需要读取一个路径/file-path。这个路径应该是从TaskManager读取的，但是我实际上是从提交的机器JobManager读取/file-path，如果我想在JobManager容器中提交作业，然后读取taskmanager上的文件，怎么办？

Answer 1

根据 Flink 作业的提交方式，其 main 方法中的代码在客户端或作业管理器中执行。如果您希望在初始化期间在每个任务管理器中执行某些操作，请将该代码放入其中一个函数的 open 方法中。