为什么Apache Flink不在Windows上运行？

Question

我是新手，我是第一次使用Apache Flink。我已经在Windows中下载了Flink-1.14.4-bin-scala_2.12版本，我已经安装了Cygwin在Windows中运行SH文件。我还在Windows 10 OS上安装了Java 11。

我正在关注据我执行脚本 bin/start-cluster.sh ，这在cygwin终端显示

启动群集。
在主持人Simli上启动独立的守护程序。
在主机上启动taskexecutor守护程序。

但是，在执行此命令之后，Apache Flink Web UI并未在http：// localhost：8081/

我在这里丢失一些非常简单的东西吗？ 我还提到一个问题，但似乎我已经安​​装了正确的Java版本（Java 11）。

Answer 1

Windows和Cygwin上的线路结尾字符似乎存在问题。

1. 启动cygwin shell。

2. 通过输入来确定您的主目录

； PWD

这将返回Cygwin root路径下的路径。

3. 使用Notepad，WordPad或其他文本编辑器在主目录中打开文件.bash_profile并附加以下内容（如果不存在文件，则必须创建它）：

$ export shellopts

$ SET -O IGNCR

保存文件并打开一个新的bash shell（只是句子导出...并设置...而不是$，以防万一）。

4. 暂时文件夹名称上还有另一个错误，其中包含字符'：'，并且它在Windows上不起作用，可以修复此问题edit /conf/flink-conf.yaml并添加

taskmanager.resource-ID： TM_LOCALHOST

此设置的缺点是每个执行情况都不会有特定的文件夹，并且它将在Cygwin

参考的临时文件夹上具有该名称：

flink任务管理器未启动问题

flink的windows/cygwin手动修复

apace flink：任务经理未能启动-Mapohl的评论

flink的邮件列表

Answer 2

对于Newbie，为了尽快体验Flink的新功能，并避免安装环境的麻烦，我认为您可以尝试安装Docker。

Flink Docker-compose.yml：

version: '2.1'
services:
  sql-client:
    user: flink:flink
    image: yuxialuo/flink-sql-client:1.13.2.v1 
    depends_on:
      - jobmanager
      - mysql
    environment:
      FLINK_JOBMANAGER_HOST: jobmanager
      MYSQL_HOST: mysql
    volumes:
      - shared-tmpfs:/tmp/iceberg
  jobmanager:
    user: flink:flink
    image: flink:1.13.2-scala_2.11
    ports:
      - "8081:8081"
    command: jobmanager
    environment:
      - |
        FLINK_PROPERTIES=
        jobmanager.rpc.address: jobmanager
    volumes:
      - shared-tmpfs:/tmp/iceberg
  taskmanager:
    user: flink:flink
    image: flink:1.13.2-scala_2.11
    depends_on:
      - jobmanager
    command: taskmanager
    environment:
      - |
        FLINK_PROPERTIES=
        jobmanager.rpc.address: jobmanager
        taskmanager.numberOfTaskSlots: 2
    volumes:
      - shared-tmpfs:/tmp/iceberg
  mysql:
    image: debezium/example-mysql:1.1
    ports:
      - "3306:3306"
    environment:
      - MYSQL_ROOT_PASSWORD=123456
      - MYSQL_USER=mysqluser
      - MYSQL_PASSWORD=mysqlpw

volumes:
  shared-tmpfs:
    driver: local
    driver_opts:
      type: "tmpfs"
      device: "tmpfs"

然后在docker-compose.yml文件所在的当前目录中启动flink组件。

docker-compose up -d

此命令将自动启动Docker中定义的所有容器以独立模式组成配置。

您可以通过访问来检查Flink是否正常运行：http：// localhost：8081/

您也可以在Dockerhub上搜索所需的图像的Flink版本：https：//hub.dock.docker.com/r/apache/flink /标签