首页 文章

Flink Windows HA

提问于
浏览
0

我正在研究用于数据流的apache flink(1.3.1),我必须在Windows Server 2012 R2下设置它,我在Flink HA设置上遇到了问题 . 任何帮助是极大的赞赏 . 谢谢 .

以下是设置详细信息,我有5个服务器,2个用于作业管理器HA,2个用于任务管理器HA,最后一个(资源服务器)用于保存所有恢复,保存点或检查点文件 .

  • 我已将资源服务器映射为所有其他服务器中的'Y'网络驱动器 .

  • 在flink-conf.yaml high-availability.storageDir: file:///cygdrive/Y/flink-recovery

  • 它可以从Cygwin终端访问资源服务器,路径为'cygdrive/Y/flink-recovery'

问题:当我在Cygwin下运行start-cluster.sh命令时,Flink HA将在所有Flink服务器中创建一个文件夹'c:/ cygdrive / Y / flink-recovery',而不是在资源服务器中创建恢复文件 .

我知道'hdfs://'协议是存储目录设置的替代方案,但'file://'协议可以在Flink HA中工作吗?

1 回答

  • 0

    我发现使用“bin / statrt-cluster.sh”在Cygwin中启动集群将始终创建本地文件 . 如果我使用“bin / jobmanager.sh启动集群IP”,并且其他节点使用“bin / taskmanager.sh start”,则可以访问网络驱动器 .

    我认为“bin / start-cluster.sh”命令将以管理员身份运行 . 我尝试过以管理员身份运行,它无法列出网络驱动器,但作为用户运行可以在Cygwin中列出网络驱动器 .

    谢谢

相关问题