Flink Windows HA



我正在开发用于数据流的apache flink(1.3.1),我必须在Windows Server 2012 R2下进行设置,我在flink HA设置上遇到了问题。非常感谢您的帮助。谢谢

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

  1. 我已将资源服务器映射为所有其他中的"Y"网络驱动器服务器
  2. 在flink-conf.yaml高可用性.storageDir:file:///cygdrive/Y/flink-recovery
  3. 它可以从Cygwin终端访问资源服务器,路径为"cygdrive/Y/flink recovery">

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

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

我发现在Cygwin中使用"bin/start-cluster.sh"启动集群总是会创建本地文件。如果我使用"bin/jobmanager.sh启动群集IP",而其他节点使用"bin/taskmanager.sh开始",它可以访问网络驱动器。

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

感谢

相关内容

  • 没有找到相关文章

最新更新