你有没有遇到过这种情况高高兴兴从官网下载了最新版的 Apache Flink解压完切到bin目录突然发现以前那些熟悉的.bat启动文件全都没了。start-cluster.bat不见了flink.bat不见了连stop-cluster.bat也消失得一干二净只剩下一排.sh脚本。第一反应是“下错包了”第二反应是“杀毒软件把 bat 干掉了”其实都不是。这是新版 Flink 在 Windows 支持策略上的一个明显变化。这篇文章我就把这段时间折腾 Flink 新版本无 bat 启动文件的所有解决方式、踩坑过程和代码原原本本梳理出来给同样被这个问题卡住的朋友一份可以直接抄作业的答案。1. 先搞清楚状况新版 Flink 的 bin 目录里到底少了什么1.1 少了哪些文件影响有多大老版本的 Flink 在 Windows 上的体验还是很“无脑”的。解压flink-1.13.x-bin-scala_2.12.zip进入bin目录能看到一串.bat文件flink.bat命令行客户端的 Windows 入口用来提交作业、取消作业、查看状态start-cluster.bat一键启动 Standalone 本地集群默认拉起一个 JobManager 和一个 TaskManagerstop-cluster.bat一键停止本地集群sql-client.bat启动 SQL Client 的 Windows 脚本其他还有yarn-session.bat、taskmanager.bat等不过本地开发最常用的就是前三个。新版本解压后bin目录里只剩下flink、start-cluster.sh、stop-cluster.sh、sql-client.sh这类 Unix/Linux 脚本。如果你一直习惯写命令行的参数量不大可能觉得“没有 bat 也不是大事”但对靠双击.bat快速起环境的 Windows 用户来说这就等于把“启动入口”直接藏起来了。最直接的影响有三个本地想做快速验证时少了最顺手的启动方式部分公司内网 Windows 机器上没有 Git Bash、WSL也没有 Docker运行环境非常受限新人接手项目时看文档里的start-cluster.bat提示对着磁盘里的目录却找不到文件第一反应就是“包是不是坏了”。1.2 为什么官方敢把这些 bat 文件移除很多朋友会问Flink 是 Apache 顶级项目连 Windows 启动脚本都不维护了吗这个问题背后是现实工程决策。Flink 的主要生产运行环境是 Linux 服务器、容器集群、云原生环境Windows 本地跑 Flink 更多是开发调试或教学演示。bat 文件的维护成本不高但每个版本的 Java 参数、JVM 内存配置、类名变动都需要同步跟改社区维护精力有限慢慢就把 Windows 脚本从“正式支持”降级成“不再跟新版本同步发布”。说白了官方不是逼你不用 Windows而是把 Windows 环境下怎么启动 Flink 这个问题交给了开发者自己去适配。新版把.sh脚本保留但不再提供.bat意味着你要是非要在 Windows 上双击启动就需要自己动手补上这个文件或者换一种方式把.sh脚本跑起来。1.3 动手前先确认自己的使用场景在决定用哪种方案之前先问自己一个问题你启动 Flink 是拿来干什么的如果只是学习 API、调试 WordCount、跑一条 Flink SQL那完全没必要死磕 Windows 原生 bat用 Git Bash 跑官方.sh是成本最低的路径。如果你的开发机是工作用的 Windows 笔记本平时习惯双击窗口不希望每次都依赖外置工具那么自己写一个start-cluster.bat放进bin目录更舒服。如果你们团队的集群环境本来就走 Docker 容器那你纠结的“bat 文件”根本没有存在的意义直接用容器编排文件才是正路。方案没有绝对的好坏只有适不适合当前环境。下面我把三条路全部展开讲你按自己的情况选一条走就行。2. 最快方案用 Git Bash 直接跑官方 .sh 脚本2.1 安装 Git Bash 并打开正确目录Git Bash 是 Windows 下最轻量的 Unix 模拟环境。很多开发者电脑上已经装了 Git for Windows如果没装去官网下载安装包一路默认安装右键菜单里就会出现“Git Bash Here”。安装完以后打开 Flink 解压出来的目录在空白处右键选择“Git Bash Here”。注意这里最怕脑子一热在下载目录里直接右键结果bin脚本路径全乱。确保当前目录层级是flink-xxx的根目录也就是能看到bin、conf、lib、examples这些文件夹的那一层。进入目录后先检查 Java 环境是否够用java -version如果提示java命令不存在说明你的JAVA_HOME没配好或者 JDK 的bin目录没进 Path。新版 Flink 要求 JDK 8、11 或 17太老或者太新都可能出问题。检查完 Java再看一眼conf/flink-conf.yaml确认内存参数没有设置到本机物理内存扛不住的程度。2.2 启动、提交作业和关停集群的三条命令环境没问题以后启动集群就一行./bin/start-cluster.sh脚本执行完终端会出现类似Starting cluster.的提示并且会通过jps能看到StandaloneSessionClusterEntrypoint和TaskManagerRunner两个进程。这时候打开浏览器访问http://localhost:8081能看到 Flink Web UI说明集群已经起来了。接下来提交一个示例作业试试水./bin/flink run -d examples/streaming/WordCount.jar --input README.txt --output /tmp/output如果你用的是较新版本命令行参数和旧的略有差异建议先跑一下自带的示例且不指定 input/output./bin/flink run -d examples/streaming/WordCount.jar这会启动一个无限流作业其实默认会跑自带测试数据运行完可以在 Web UI 的 Completed Jobs 里看到结果。测试完关集群回到最开始那个 Git Bash 窗口执行./bin/stop-cluster.shstop-cluster.sh会通知 JobManager 和 TaskManager 优雅关闭比直接在任务管理器里杀进程要干净得多。2.3 路径、换行符和内存配置这三个坑这个方案听起来很顺但我第一次跑的时候也碰到过几个问题。第一个坑是路径里有空格。Windows 用户喜欢把软件解压到C:\Program Files这种带空格的目录虽然 Git Bash 大多数时候能处理但后续脚本拼接路径时很容易出幺蛾子。建议把 Flink 解压到一个无空格路径比如D:\flink-1.19.1省心很多。第二个坑是换行符。从 Windows 自带解压工具解出来.sh脚本偶尔会带着 CRLF 换行符执行时报/bin/sh^M: bad interpreter。解决办法也很简单在 Git Bash 里执行sed -i s/\r$// bin/*.sh把bin目录下所有 shell 脚本的行尾统一改成 LF 就行。如果sed不顺手也可以用 dos2unix但那个工具不一定默认装了。第三个坑是内存配置。默认的conf/flink-conf.yaml里JobManager 和 TaskManager 的单进程内存通常配得比较常规但如果你电脑内存只有 8G再开 IDEA、浏览器、微信跑 Flink 时可能直接启动就挂。改jobmanager.memory.process.size和taskmanager.memory.process.size时别只调小一个两个都要看不然 TaskManager 连接不上 JobManager 的排查过程会绕很多弯路。3. 一劳永逸方案手写 start-cluster.bat 和 flink.bat3.1 想写 bat先搞懂 Flink 本地集群的启动类Git Bash 方案虽然快但很多 Windows 用户还是希望双击.bat就把事情办了。这时候我们需要自己写一个 bat 文件。别觉得这是什么黑科技搞懂背后的原理之后你会发现它比想象中简单。Flink Standalone 本地集群本质上就是两个 JVM 进程JobManager对应的启动类是org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypointTaskManager对应的启动类是org.apache.flink.runtime.taskexecutor.TaskManagerRunner。命令行的入口则是org.apache.flink.client.cli.CliFrontend。只要 classpath 能覆盖 Flinklib目录下所有的 jar 包并且FLINK_CONF_DIR环境变量指到conf目录直接用java命令就能把集群拉起来。之所以官方不提供.bat并不是底层启动逻辑变了而是没有维护 Windows 脚本而已。想明白这一点代码就好写了。3.2 start-cluster.bat 完整实现下面这个脚本是我实际在 Flink 1.18/1.19 上验证过的放到bin目录下就能用。把它保存为start-cluster.bat注意文件编码用 ANSI 或 UTF-8 都行脚本里没有中文字符就不会乱码echo off setlocal EnableDelayedExpansion chcp 65001 nul rem 基本目录设置 set FLINK_HOME%~dp0.. set FLINK_CONF_DIR%FLINK_HOME%\conf set FLINK_LIB_DIR%FLINK_HOME%\lib set FLINK_PLUGINS_DIR%FLINK_HOME%\plugins set FLINK_LOG_DIR%FLINK_HOME%\log rem 检查 JAVA_HOME if not defined JAVA_HOME ( echo [ERROR] JAVA_HOME is not defined. Please set JAVA_HOME first. exit /b 1 ) set JAVA%JAVA_HOME%\bin\java.exe if not exist %JAVA% ( echo [ERROR] Java executable not found: %JAVA% exit /b 1 ) rem 拼接 classpath set FLINK_CLASSPATH for %%f in (%FLINK_LIB_DIR%\*.jar) do ( set FLINK_CLASSPATH!FLINK_CLASSPATH!;%%f ) if exist %FLINK_PLUGINS_DIR% ( for /d %%d in (%FLINK_PLUGINS_DIR%\*) do ( for %%f in (%%d\*.jar) do ( set FLINK_CLASSPATH!FLINK_CLASSPATH!;%%f ) ) ) if defined FLINK_CLASSPATH set FLINK_CLASSPATH%FLINK_CLASSPATH:~1% rem 准备日志目录 if not exist %FLINK_LOG_DIR% mkdir %FLINK_LOG_DIR% echo Starting Flink JobManager... start Flink JobManager %JAVA% -Dlog.file%FLINK_LOG_DIR%\jobmanager.log -Dlog4j.configurationFilefile:%FLINK_HOME%\conf\log4j-console.properties -Dlogback.configurationFilefile:%FLINK_HOME%\conf\logback-console.xml -cp %FLINK_CLASSPATH% org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint echo Starting Flink TaskManager... start Flink TaskManager %JAVA% -Dlog.file%FLINK_LOG_DIR%\taskmanager.log -Dlog4j.configurationFilefile:%FLINK_HOME%\conf\log4j-console.properties -Dlogback.configurationFilefile:%FLINK_HOME%\conf\logback-console.xml -cp %FLINK_CLASSPATH% org.apache.flink.runtime.taskexecutor.TaskManagerRunner echo. echo Flink cluster is starting. Wait a few seconds and open http://localhost:8081 endlocal这个脚本逻辑不复杂我挑几个关键点解释一下。FLINK_HOME%~dp0..是核心技巧。%~dp0表示 bat 文件所在目录末尾带\后面再接..就是 Flink 的根目录。这样做的好处是脚本放到bin下以后不管你的 Flink 解压到哪个盘它都能自动定位。setlocal EnableDelayedExpansion加!FLINK_CLASSPATH!这种写法是为了在for循环里动态拼接字符串。如果不用延迟变量扩展%FLINK_CLASSPATH%在循环里永远取到初始空值classpath 拼完什么都没有。日志参数里同时挂了 log4j 和 logback 的配置实际运行时 Flink 会按内部日志框架自动选一个生效两个都写是为了兼容不同版本默认日志框架的差异。如果你发现日志输出没有按预期写到文件去掉其中一个配置试试。3.3 stop-cluster.bat 与 flink.bat 配套使用有启动就得有关停。Windows 下最靠谱的停止方式不是杀进程窗口标题而是按进程命令行匹配把包含StandaloneSessionClusterEntrypoint和TaskManagerRunner的 Java 进程找出来结束掉。保存stop-cluster.bat到bin目录echo off echo Stopping Flink JobManager... powershell -NoProfile -Command Get-CimInstance Win32_Process | Where-Object { $_.CommandLine -like *StandaloneSessionClusterEntrypoint* } | ForEach-Object { Stop-Process -Id $_.ProcessId -Force } echo Stopping Flink TaskManager... powershell -NoProfile -Command Get-CimInstance Win32_Process | Where-Object { $_.CommandLine -like *TaskManagerRunner* } | ForEach-Object { Stop-Process -Id $_.ProcessId -Force } echo Flink cluster stopped.这个脚本有三个好处不依赖额外工具Windows 10 和 Windows 11 自带的 PowerShell 就能跑不会误杀其他 Java 进程因为匹配条件很精准批处理窗口本身不包含关键词不会被自己误杀。接着补一个flink.bat用来替代官方那个消失的命令行入口echo off setlocal EnableDelayedExpansion set FLINK_HOME%~dp0.. set FLINK_CONF_DIR%FLINK_HOME%\conf set FLINK_LIB_DIR%FLINK_HOME%\lib set FLINK_CLASSPATH for %%f in (%FLINK_LIB_DIR%\*.jar) do ( set FLINK_CLASSPATH!FLINK_CLASSPATH!;%%f ) if exist %FLINK_HOME%\plugins ( for /d %%d in (%FLINK_HOME%\plugins\*) do ( for %%f in (%%d\*.jar) do ( set FLINK_CLASSPATH!FLINK_CLASSPATH!;%%f ) ) ) if defined FLINK_CLASSPATH set FLINK_CLASSPATH%FLINK_CLASSPATH:~1% set JAVA%JAVA_HOME%\bin\java.exe %JAVA% -cp %FLINK_CLASSPATH% org.apache.flink.client.cli.CliFrontend %* endlocal写完后你可以这样用bin\start-cluster.bat bin\flink.bat run -d examples\streaming\WordCount.jar bin\stop-cluster.batflink.bat最核心的就是把FLINK_CONF_DIR环境变量设好然后调用CliFrontend。很多网上抄来的脚本会漏掉FLINK_CONF_DIR结果命令死活找不到flink-conf.yaml报一些莫名其妙的信息。3.4 脚本不只为了启动还是理解 Flink 结构的入口有人会问既然有官方.sh脚本为什么还要花时间自己写 bat我的体会是写一遍 bat你对 Flink 的依赖关系反而更清楚了。你会记住 classpath 必须包含lib下所有 jar你会记住插件目录plugins需要单独拼进去你会记住除了启动类之外还需要一个FLINK_CONF_DIR指向配置目录你还会记住log目录是 Flink 排查问题的第一现场。这些知识在后续排查线上问题时都非常有用尤其是遇到“为什么我的 Flink 看起来起了但 Web UI 就是打不开”这种模糊问题时你能立刻想到去log目录看日志而不是重装一遍。以后 Flink 升级你只需要把这三个 bat 文件原样复制到新版本的bin目录改一下FLINK_HOME对应的路径逻辑即可。因为脚本用的都是相对路径复制过去基本不用改只要目录结构不变。4. 用 WSL2 或 Docker 绕过整个 Windows 兼容问题4.1 WSL2 里起 Flink 的完整流程如果你的痛点不是“Windows 上双击”而是“我想在 Windows 上有一个尽量接近生产的 Linux 环境”那 WSL2 是比 Git Bash 更完整的选择。先把 WSL2 装好管理员 PowerShell 执行wsl --install -d Ubuntu装完重启进入 Ubuntu 终端更新 apt 源并装 JDKsudo apt update sudo apt install openjdk-11-jdk -y然后把 Flink 的 tar.gz 包解压到 WSL 内比如/opt/flinksudo tar -zxvf flink-1.19.1-bin-scala_2.12.tgz -C /opt cd /opt/flink-1.19.1启动命令和 Linux 上完全一致./bin/start-cluster.sh在 Windows 浏览器里直接访问http://localhost:8081也能看到 Web UI因为 WSL2 默认会把 localhost 转发到宿主机。遇到访问不了的情况先检查rest.bind-address是不是被配成了0.0.0.0或127.0.0.1再检查 Windows 防火墙有没有拦 WSL 的流量。4.2 Docker Desktop 一行命令跑起来比 WSL2 更节省时间的是 Docker Desktop 方案。前提是你在 Windows 上已经装好 Docker Desktop并且运行引擎是 WSL2 backend。直接拉官方镜像暴露两个关键端口:docker run -d --name flink-jobmanager \ -p 8081:8081 -p 6123:6123 \ flink:1.19.1 \ jobmanager再启动一个 TaskManager让它连上 JobManagerdocker run -d --name flink-taskmanager \ --link flink-jobmanager:jobmanager \ flink:1.19.1 \ taskmanager这里要注意官方 Docker 镜像里的jobmanager和taskmanager是 entrypoint 脚本接收的命令参数不是随便起的名字。第一次跑的时候如果提示找不到入口可以先执行docker run --rm flink:1.19.1 bash -c ls /opt/flink/bin看一眼镜像内部分布再调整命令。搞完以后 Web UI 同样访问http://localhost:8081日志可以用docker logs flink-jobmanager查看。4.3 什么情况才应该用这套而不是死磕 batWSL2 和 Docker 这两条路虽然“正统”但并不意味着所有人都要学。如果你的机器配置一般开一个 Docker Desktop 可能占用 2G 甚至更高内存再跑 Flink 集群电脑风扇能起飞。如果你的项目需要访问 Windows 本地文件系统里的某些数据源在 WSL2 和 Docker 里挂载 Windows 路径会比较绕反而不如直接在 Windows 上用 Git Bash 简单。所以我自己的判断标准是只有当你需要在 Windows 上模拟 Linux 运行环境、或者要跑一些依赖 Hadoop/云原生的复杂部署时才用 WSL2/Docker单纯想写一个 Flink SQL 验证逻辑用 Git Bash 或自己写的 bat 就够了。5. 新版本启动后最容易踩的一串坑5.1 JAVA_HOME 和 Java 版本不对跑 Flink 之前java -version是最该先跑的命令。新版 Flink 对 Java 版本有要求通常支持 JDK 8、11 和 17。如果你装了 JDK 21部分老版本 Flink 会直接报UnsupportedClassVersionError或者启动到一半失败。另一个问题是JAVA_HOME指向了 JRE 而非 JDK。Flink 虽然是运行 Java 程序但在某些编译场景需要javac环境不完整的时候会出现不可名状的错误。Windows 上设置JAVA_HOME时不要带末尾的反斜杠比如填C:\Program Files\Java\jdk-11.0.16而不是...\jdk-11.0.16\不然拼路径的时候容易出现双反斜杠问题。5.2 找不到主类或类加载异常自己写 bat 最常见的问题就是 classpath 没拼对启动时报Error: Could not find or load main class org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint这种情况十有八九是for %%f in (%FLINK_LIB_DIR%\*.jar)没有生效要么FLINK_LIB_DIR路径不对要么EnableDelayedExpansion没打开。还有一种情况是报NoClassDefFoundError说明主类找到了但依赖的 jar 不在 classpath 里。新版 Flink 把很多依赖拆到了plugins目录下比如flink-azure-fs-hadoop、flink-s3-fs-hadoop这类文件系统插件不主动加入 classpath 就会缺类。手写 bat 时一定要把plugins目录下的子目录 jar 也循环拼进去。5.3 Web UI 访问不了和端口占用启动脚本执行完浏览器访问http://localhost:8081最怕看到“无法访问此网站”。先别急着怀疑 Flink 坏了按顺序排查两步。先看进程是否存在命令行执行jps如果能看到StandaloneSessionClusterEntrypoint和TaskManagerRunner说明 JVM 起来了。再看日志进入log目录找最新的flink-*-standalonesession-*.log搜索Rest endpoint listening at或Web frontend listening。如果日志里说端口被占用修改conf/flink-conf.yaml里的rest.port改成 8082 或任意空闲端口。还有一个小坑很多 Windows 用户会用 360 或腾讯管家某些“网络保护”功能会拦截本机回环端口的访问。遇到 Web UI 始终打不开但日志正常时临时关掉安全软件试一下。这个问题在技术文档里基本不会写但现实中我真的遇到过好几次。5.4 资源不足导致的启动即挂有些机器配置不高一执行start-cluster.sh或手写 bat 时窗口刚起就闪退日志里全是OutOfMemoryError。问题基本都出在内存参数上。打开conf/flink-conf.yaml关注这几个参数jobmanager.memory.process.size: 1600m taskmanager.memory.process.size: 1728m taskmanager.memory.managed.size: 0.0如果你的电脑内存只有 8G建议把进程内存调到 800m 和 1024m 试试。taskmanager.memory.managed.size可以暂时设成 0让 Flink 自动分配。Windows 下还要注意不是所有“空闲内存”都能被 JVM 拿来当堆外内存用系统本身还要留一部分给桌面、浏览器、杀毒软件别把配置顶得太满。6. 按场景选方案别在启动文件上内耗6.1 这三种方案怎么选Git Bash、手写 bat、WSL2/Docker没有什么高下之分完全是场景驱动。我自己列过一个选择表你参考一下使用场景推荐方案理由快速学 Flink API跑官方示例Git Bash 跑.sh无额外学习成本启动最快Windows 桌面环境习惯双击启动手写 bat 三个文件一劳永逸环境依赖最少模拟 Linux 生产环境做完整部署WSL2能最大程度贴近线上团队协作需要统一环境Docker Desktop镜像版本一致避免“在我机器上是好的”如果你的团队里有人连 Git Bash 都不想装那我建议你直接把手写 bat 作为公共脚本提交到代码仓库。反正 Flink 目录结构是固定的三个 bat 文件就一百来行谁拉下来都能用比每个人各踩一轮坑要高效得多。6.2 几条对新手最友好的建议最后分享几个我在实际使用中总结出来的经验。第一别急着从旧版 Flink 里复制 bat 文件过来用。新版 Flink 的启动类、内存模型、配置项都有过调整老 bat 拿过来大概率会遇到类路径问题甚至启动类名都对不上。与其花时间改不如用本文的脚本重新生成。第二在 Windows 上无论用哪种方案先把log目录定位出来。Flink 的日志虽然不像大数据平台那么复杂但log/*.log里的内容比控制台完整得多。启动失败先看日志能省下大量“反复启动-关闭-再启动”的无效操作。第三也是我最想说的一点启动文件只是个入口别在这里消耗太多心力。如果你发现自己已经在“Flink 怎么启动”上折腾超过半天直接切到 Docker 方案或者找一台 Linux 服务器把精力放回真正的数据开发上。Flink 新版没有 bat 不是 bug是 Windows 生态被逐步边缘化的正常结果。搞清楚背后的机制再根据环境选一条顺手的路这个问题其实五分钟就能解决。
新版Flink Windows无bat启动文件？三种解决方案全解析
你有没有遇到过这种情况高高兴兴从官网下载了最新版的 Apache Flink解压完切到bin目录突然发现以前那些熟悉的.bat启动文件全都没了。start-cluster.bat不见了flink.bat不见了连stop-cluster.bat也消失得一干二净只剩下一排.sh脚本。第一反应是“下错包了”第二反应是“杀毒软件把 bat 干掉了”其实都不是。这是新版 Flink 在 Windows 支持策略上的一个明显变化。这篇文章我就把这段时间折腾 Flink 新版本无 bat 启动文件的所有解决方式、踩坑过程和代码原原本本梳理出来给同样被这个问题卡住的朋友一份可以直接抄作业的答案。1. 先搞清楚状况新版 Flink 的 bin 目录里到底少了什么1.1 少了哪些文件影响有多大老版本的 Flink 在 Windows 上的体验还是很“无脑”的。解压flink-1.13.x-bin-scala_2.12.zip进入bin目录能看到一串.bat文件flink.bat命令行客户端的 Windows 入口用来提交作业、取消作业、查看状态start-cluster.bat一键启动 Standalone 本地集群默认拉起一个 JobManager 和一个 TaskManagerstop-cluster.bat一键停止本地集群sql-client.bat启动 SQL Client 的 Windows 脚本其他还有yarn-session.bat、taskmanager.bat等不过本地开发最常用的就是前三个。新版本解压后bin目录里只剩下flink、start-cluster.sh、stop-cluster.sh、sql-client.sh这类 Unix/Linux 脚本。如果你一直习惯写命令行的参数量不大可能觉得“没有 bat 也不是大事”但对靠双击.bat快速起环境的 Windows 用户来说这就等于把“启动入口”直接藏起来了。最直接的影响有三个本地想做快速验证时少了最顺手的启动方式部分公司内网 Windows 机器上没有 Git Bash、WSL也没有 Docker运行环境非常受限新人接手项目时看文档里的start-cluster.bat提示对着磁盘里的目录却找不到文件第一反应就是“包是不是坏了”。1.2 为什么官方敢把这些 bat 文件移除很多朋友会问Flink 是 Apache 顶级项目连 Windows 启动脚本都不维护了吗这个问题背后是现实工程决策。Flink 的主要生产运行环境是 Linux 服务器、容器集群、云原生环境Windows 本地跑 Flink 更多是开发调试或教学演示。bat 文件的维护成本不高但每个版本的 Java 参数、JVM 内存配置、类名变动都需要同步跟改社区维护精力有限慢慢就把 Windows 脚本从“正式支持”降级成“不再跟新版本同步发布”。说白了官方不是逼你不用 Windows而是把 Windows 环境下怎么启动 Flink 这个问题交给了开发者自己去适配。新版把.sh脚本保留但不再提供.bat意味着你要是非要在 Windows 上双击启动就需要自己动手补上这个文件或者换一种方式把.sh脚本跑起来。1.3 动手前先确认自己的使用场景在决定用哪种方案之前先问自己一个问题你启动 Flink 是拿来干什么的如果只是学习 API、调试 WordCount、跑一条 Flink SQL那完全没必要死磕 Windows 原生 bat用 Git Bash 跑官方.sh是成本最低的路径。如果你的开发机是工作用的 Windows 笔记本平时习惯双击窗口不希望每次都依赖外置工具那么自己写一个start-cluster.bat放进bin目录更舒服。如果你们团队的集群环境本来就走 Docker 容器那你纠结的“bat 文件”根本没有存在的意义直接用容器编排文件才是正路。方案没有绝对的好坏只有适不适合当前环境。下面我把三条路全部展开讲你按自己的情况选一条走就行。2. 最快方案用 Git Bash 直接跑官方 .sh 脚本2.1 安装 Git Bash 并打开正确目录Git Bash 是 Windows 下最轻量的 Unix 模拟环境。很多开发者电脑上已经装了 Git for Windows如果没装去官网下载安装包一路默认安装右键菜单里就会出现“Git Bash Here”。安装完以后打开 Flink 解压出来的目录在空白处右键选择“Git Bash Here”。注意这里最怕脑子一热在下载目录里直接右键结果bin脚本路径全乱。确保当前目录层级是flink-xxx的根目录也就是能看到bin、conf、lib、examples这些文件夹的那一层。进入目录后先检查 Java 环境是否够用java -version如果提示java命令不存在说明你的JAVA_HOME没配好或者 JDK 的bin目录没进 Path。新版 Flink 要求 JDK 8、11 或 17太老或者太新都可能出问题。检查完 Java再看一眼conf/flink-conf.yaml确认内存参数没有设置到本机物理内存扛不住的程度。2.2 启动、提交作业和关停集群的三条命令环境没问题以后启动集群就一行./bin/start-cluster.sh脚本执行完终端会出现类似Starting cluster.的提示并且会通过jps能看到StandaloneSessionClusterEntrypoint和TaskManagerRunner两个进程。这时候打开浏览器访问http://localhost:8081能看到 Flink Web UI说明集群已经起来了。接下来提交一个示例作业试试水./bin/flink run -d examples/streaming/WordCount.jar --input README.txt --output /tmp/output如果你用的是较新版本命令行参数和旧的略有差异建议先跑一下自带的示例且不指定 input/output./bin/flink run -d examples/streaming/WordCount.jar这会启动一个无限流作业其实默认会跑自带测试数据运行完可以在 Web UI 的 Completed Jobs 里看到结果。测试完关集群回到最开始那个 Git Bash 窗口执行./bin/stop-cluster.shstop-cluster.sh会通知 JobManager 和 TaskManager 优雅关闭比直接在任务管理器里杀进程要干净得多。2.3 路径、换行符和内存配置这三个坑这个方案听起来很顺但我第一次跑的时候也碰到过几个问题。第一个坑是路径里有空格。Windows 用户喜欢把软件解压到C:\Program Files这种带空格的目录虽然 Git Bash 大多数时候能处理但后续脚本拼接路径时很容易出幺蛾子。建议把 Flink 解压到一个无空格路径比如D:\flink-1.19.1省心很多。第二个坑是换行符。从 Windows 自带解压工具解出来.sh脚本偶尔会带着 CRLF 换行符执行时报/bin/sh^M: bad interpreter。解决办法也很简单在 Git Bash 里执行sed -i s/\r$// bin/*.sh把bin目录下所有 shell 脚本的行尾统一改成 LF 就行。如果sed不顺手也可以用 dos2unix但那个工具不一定默认装了。第三个坑是内存配置。默认的conf/flink-conf.yaml里JobManager 和 TaskManager 的单进程内存通常配得比较常规但如果你电脑内存只有 8G再开 IDEA、浏览器、微信跑 Flink 时可能直接启动就挂。改jobmanager.memory.process.size和taskmanager.memory.process.size时别只调小一个两个都要看不然 TaskManager 连接不上 JobManager 的排查过程会绕很多弯路。3. 一劳永逸方案手写 start-cluster.bat 和 flink.bat3.1 想写 bat先搞懂 Flink 本地集群的启动类Git Bash 方案虽然快但很多 Windows 用户还是希望双击.bat就把事情办了。这时候我们需要自己写一个 bat 文件。别觉得这是什么黑科技搞懂背后的原理之后你会发现它比想象中简单。Flink Standalone 本地集群本质上就是两个 JVM 进程JobManager对应的启动类是org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypointTaskManager对应的启动类是org.apache.flink.runtime.taskexecutor.TaskManagerRunner。命令行的入口则是org.apache.flink.client.cli.CliFrontend。只要 classpath 能覆盖 Flinklib目录下所有的 jar 包并且FLINK_CONF_DIR环境变量指到conf目录直接用java命令就能把集群拉起来。之所以官方不提供.bat并不是底层启动逻辑变了而是没有维护 Windows 脚本而已。想明白这一点代码就好写了。3.2 start-cluster.bat 完整实现下面这个脚本是我实际在 Flink 1.18/1.19 上验证过的放到bin目录下就能用。把它保存为start-cluster.bat注意文件编码用 ANSI 或 UTF-8 都行脚本里没有中文字符就不会乱码echo off setlocal EnableDelayedExpansion chcp 65001 nul rem 基本目录设置 set FLINK_HOME%~dp0.. set FLINK_CONF_DIR%FLINK_HOME%\conf set FLINK_LIB_DIR%FLINK_HOME%\lib set FLINK_PLUGINS_DIR%FLINK_HOME%\plugins set FLINK_LOG_DIR%FLINK_HOME%\log rem 检查 JAVA_HOME if not defined JAVA_HOME ( echo [ERROR] JAVA_HOME is not defined. Please set JAVA_HOME first. exit /b 1 ) set JAVA%JAVA_HOME%\bin\java.exe if not exist %JAVA% ( echo [ERROR] Java executable not found: %JAVA% exit /b 1 ) rem 拼接 classpath set FLINK_CLASSPATH for %%f in (%FLINK_LIB_DIR%\*.jar) do ( set FLINK_CLASSPATH!FLINK_CLASSPATH!;%%f ) if exist %FLINK_PLUGINS_DIR% ( for /d %%d in (%FLINK_PLUGINS_DIR%\*) do ( for %%f in (%%d\*.jar) do ( set FLINK_CLASSPATH!FLINK_CLASSPATH!;%%f ) ) ) if defined FLINK_CLASSPATH set FLINK_CLASSPATH%FLINK_CLASSPATH:~1% rem 准备日志目录 if not exist %FLINK_LOG_DIR% mkdir %FLINK_LOG_DIR% echo Starting Flink JobManager... start Flink JobManager %JAVA% -Dlog.file%FLINK_LOG_DIR%\jobmanager.log -Dlog4j.configurationFilefile:%FLINK_HOME%\conf\log4j-console.properties -Dlogback.configurationFilefile:%FLINK_HOME%\conf\logback-console.xml -cp %FLINK_CLASSPATH% org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint echo Starting Flink TaskManager... start Flink TaskManager %JAVA% -Dlog.file%FLINK_LOG_DIR%\taskmanager.log -Dlog4j.configurationFilefile:%FLINK_HOME%\conf\log4j-console.properties -Dlogback.configurationFilefile:%FLINK_HOME%\conf\logback-console.xml -cp %FLINK_CLASSPATH% org.apache.flink.runtime.taskexecutor.TaskManagerRunner echo. echo Flink cluster is starting. Wait a few seconds and open http://localhost:8081 endlocal这个脚本逻辑不复杂我挑几个关键点解释一下。FLINK_HOME%~dp0..是核心技巧。%~dp0表示 bat 文件所在目录末尾带\后面再接..就是 Flink 的根目录。这样做的好处是脚本放到bin下以后不管你的 Flink 解压到哪个盘它都能自动定位。setlocal EnableDelayedExpansion加!FLINK_CLASSPATH!这种写法是为了在for循环里动态拼接字符串。如果不用延迟变量扩展%FLINK_CLASSPATH%在循环里永远取到初始空值classpath 拼完什么都没有。日志参数里同时挂了 log4j 和 logback 的配置实际运行时 Flink 会按内部日志框架自动选一个生效两个都写是为了兼容不同版本默认日志框架的差异。如果你发现日志输出没有按预期写到文件去掉其中一个配置试试。3.3 stop-cluster.bat 与 flink.bat 配套使用有启动就得有关停。Windows 下最靠谱的停止方式不是杀进程窗口标题而是按进程命令行匹配把包含StandaloneSessionClusterEntrypoint和TaskManagerRunner的 Java 进程找出来结束掉。保存stop-cluster.bat到bin目录echo off echo Stopping Flink JobManager... powershell -NoProfile -Command Get-CimInstance Win32_Process | Where-Object { $_.CommandLine -like *StandaloneSessionClusterEntrypoint* } | ForEach-Object { Stop-Process -Id $_.ProcessId -Force } echo Stopping Flink TaskManager... powershell -NoProfile -Command Get-CimInstance Win32_Process | Where-Object { $_.CommandLine -like *TaskManagerRunner* } | ForEach-Object { Stop-Process -Id $_.ProcessId -Force } echo Flink cluster stopped.这个脚本有三个好处不依赖额外工具Windows 10 和 Windows 11 自带的 PowerShell 就能跑不会误杀其他 Java 进程因为匹配条件很精准批处理窗口本身不包含关键词不会被自己误杀。接着补一个flink.bat用来替代官方那个消失的命令行入口echo off setlocal EnableDelayedExpansion set FLINK_HOME%~dp0.. set FLINK_CONF_DIR%FLINK_HOME%\conf set FLINK_LIB_DIR%FLINK_HOME%\lib set FLINK_CLASSPATH for %%f in (%FLINK_LIB_DIR%\*.jar) do ( set FLINK_CLASSPATH!FLINK_CLASSPATH!;%%f ) if exist %FLINK_HOME%\plugins ( for /d %%d in (%FLINK_HOME%\plugins\*) do ( for %%f in (%%d\*.jar) do ( set FLINK_CLASSPATH!FLINK_CLASSPATH!;%%f ) ) ) if defined FLINK_CLASSPATH set FLINK_CLASSPATH%FLINK_CLASSPATH:~1% set JAVA%JAVA_HOME%\bin\java.exe %JAVA% -cp %FLINK_CLASSPATH% org.apache.flink.client.cli.CliFrontend %* endlocal写完后你可以这样用bin\start-cluster.bat bin\flink.bat run -d examples\streaming\WordCount.jar bin\stop-cluster.batflink.bat最核心的就是把FLINK_CONF_DIR环境变量设好然后调用CliFrontend。很多网上抄来的脚本会漏掉FLINK_CONF_DIR结果命令死活找不到flink-conf.yaml报一些莫名其妙的信息。3.4 脚本不只为了启动还是理解 Flink 结构的入口有人会问既然有官方.sh脚本为什么还要花时间自己写 bat我的体会是写一遍 bat你对 Flink 的依赖关系反而更清楚了。你会记住 classpath 必须包含lib下所有 jar你会记住插件目录plugins需要单独拼进去你会记住除了启动类之外还需要一个FLINK_CONF_DIR指向配置目录你还会记住log目录是 Flink 排查问题的第一现场。这些知识在后续排查线上问题时都非常有用尤其是遇到“为什么我的 Flink 看起来起了但 Web UI 就是打不开”这种模糊问题时你能立刻想到去log目录看日志而不是重装一遍。以后 Flink 升级你只需要把这三个 bat 文件原样复制到新版本的bin目录改一下FLINK_HOME对应的路径逻辑即可。因为脚本用的都是相对路径复制过去基本不用改只要目录结构不变。4. 用 WSL2 或 Docker 绕过整个 Windows 兼容问题4.1 WSL2 里起 Flink 的完整流程如果你的痛点不是“Windows 上双击”而是“我想在 Windows 上有一个尽量接近生产的 Linux 环境”那 WSL2 是比 Git Bash 更完整的选择。先把 WSL2 装好管理员 PowerShell 执行wsl --install -d Ubuntu装完重启进入 Ubuntu 终端更新 apt 源并装 JDKsudo apt update sudo apt install openjdk-11-jdk -y然后把 Flink 的 tar.gz 包解压到 WSL 内比如/opt/flinksudo tar -zxvf flink-1.19.1-bin-scala_2.12.tgz -C /opt cd /opt/flink-1.19.1启动命令和 Linux 上完全一致./bin/start-cluster.sh在 Windows 浏览器里直接访问http://localhost:8081也能看到 Web UI因为 WSL2 默认会把 localhost 转发到宿主机。遇到访问不了的情况先检查rest.bind-address是不是被配成了0.0.0.0或127.0.0.1再检查 Windows 防火墙有没有拦 WSL 的流量。4.2 Docker Desktop 一行命令跑起来比 WSL2 更节省时间的是 Docker Desktop 方案。前提是你在 Windows 上已经装好 Docker Desktop并且运行引擎是 WSL2 backend。直接拉官方镜像暴露两个关键端口:docker run -d --name flink-jobmanager \ -p 8081:8081 -p 6123:6123 \ flink:1.19.1 \ jobmanager再启动一个 TaskManager让它连上 JobManagerdocker run -d --name flink-taskmanager \ --link flink-jobmanager:jobmanager \ flink:1.19.1 \ taskmanager这里要注意官方 Docker 镜像里的jobmanager和taskmanager是 entrypoint 脚本接收的命令参数不是随便起的名字。第一次跑的时候如果提示找不到入口可以先执行docker run --rm flink:1.19.1 bash -c ls /opt/flink/bin看一眼镜像内部分布再调整命令。搞完以后 Web UI 同样访问http://localhost:8081日志可以用docker logs flink-jobmanager查看。4.3 什么情况才应该用这套而不是死磕 batWSL2 和 Docker 这两条路虽然“正统”但并不意味着所有人都要学。如果你的机器配置一般开一个 Docker Desktop 可能占用 2G 甚至更高内存再跑 Flink 集群电脑风扇能起飞。如果你的项目需要访问 Windows 本地文件系统里的某些数据源在 WSL2 和 Docker 里挂载 Windows 路径会比较绕反而不如直接在 Windows 上用 Git Bash 简单。所以我自己的判断标准是只有当你需要在 Windows 上模拟 Linux 运行环境、或者要跑一些依赖 Hadoop/云原生的复杂部署时才用 WSL2/Docker单纯想写一个 Flink SQL 验证逻辑用 Git Bash 或自己写的 bat 就够了。5. 新版本启动后最容易踩的一串坑5.1 JAVA_HOME 和 Java 版本不对跑 Flink 之前java -version是最该先跑的命令。新版 Flink 对 Java 版本有要求通常支持 JDK 8、11 和 17。如果你装了 JDK 21部分老版本 Flink 会直接报UnsupportedClassVersionError或者启动到一半失败。另一个问题是JAVA_HOME指向了 JRE 而非 JDK。Flink 虽然是运行 Java 程序但在某些编译场景需要javac环境不完整的时候会出现不可名状的错误。Windows 上设置JAVA_HOME时不要带末尾的反斜杠比如填C:\Program Files\Java\jdk-11.0.16而不是...\jdk-11.0.16\不然拼路径的时候容易出现双反斜杠问题。5.2 找不到主类或类加载异常自己写 bat 最常见的问题就是 classpath 没拼对启动时报Error: Could not find or load main class org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint这种情况十有八九是for %%f in (%FLINK_LIB_DIR%\*.jar)没有生效要么FLINK_LIB_DIR路径不对要么EnableDelayedExpansion没打开。还有一种情况是报NoClassDefFoundError说明主类找到了但依赖的 jar 不在 classpath 里。新版 Flink 把很多依赖拆到了plugins目录下比如flink-azure-fs-hadoop、flink-s3-fs-hadoop这类文件系统插件不主动加入 classpath 就会缺类。手写 bat 时一定要把plugins目录下的子目录 jar 也循环拼进去。5.3 Web UI 访问不了和端口占用启动脚本执行完浏览器访问http://localhost:8081最怕看到“无法访问此网站”。先别急着怀疑 Flink 坏了按顺序排查两步。先看进程是否存在命令行执行jps如果能看到StandaloneSessionClusterEntrypoint和TaskManagerRunner说明 JVM 起来了。再看日志进入log目录找最新的flink-*-standalonesession-*.log搜索Rest endpoint listening at或Web frontend listening。如果日志里说端口被占用修改conf/flink-conf.yaml里的rest.port改成 8082 或任意空闲端口。还有一个小坑很多 Windows 用户会用 360 或腾讯管家某些“网络保护”功能会拦截本机回环端口的访问。遇到 Web UI 始终打不开但日志正常时临时关掉安全软件试一下。这个问题在技术文档里基本不会写但现实中我真的遇到过好几次。5.4 资源不足导致的启动即挂有些机器配置不高一执行start-cluster.sh或手写 bat 时窗口刚起就闪退日志里全是OutOfMemoryError。问题基本都出在内存参数上。打开conf/flink-conf.yaml关注这几个参数jobmanager.memory.process.size: 1600m taskmanager.memory.process.size: 1728m taskmanager.memory.managed.size: 0.0如果你的电脑内存只有 8G建议把进程内存调到 800m 和 1024m 试试。taskmanager.memory.managed.size可以暂时设成 0让 Flink 自动分配。Windows 下还要注意不是所有“空闲内存”都能被 JVM 拿来当堆外内存用系统本身还要留一部分给桌面、浏览器、杀毒软件别把配置顶得太满。6. 按场景选方案别在启动文件上内耗6.1 这三种方案怎么选Git Bash、手写 bat、WSL2/Docker没有什么高下之分完全是场景驱动。我自己列过一个选择表你参考一下使用场景推荐方案理由快速学 Flink API跑官方示例Git Bash 跑.sh无额外学习成本启动最快Windows 桌面环境习惯双击启动手写 bat 三个文件一劳永逸环境依赖最少模拟 Linux 生产环境做完整部署WSL2能最大程度贴近线上团队协作需要统一环境Docker Desktop镜像版本一致避免“在我机器上是好的”如果你的团队里有人连 Git Bash 都不想装那我建议你直接把手写 bat 作为公共脚本提交到代码仓库。反正 Flink 目录结构是固定的三个 bat 文件就一百来行谁拉下来都能用比每个人各踩一轮坑要高效得多。6.2 几条对新手最友好的建议最后分享几个我在实际使用中总结出来的经验。第一别急着从旧版 Flink 里复制 bat 文件过来用。新版 Flink 的启动类、内存模型、配置项都有过调整老 bat 拿过来大概率会遇到类路径问题甚至启动类名都对不上。与其花时间改不如用本文的脚本重新生成。第二在 Windows 上无论用哪种方案先把log目录定位出来。Flink 的日志虽然不像大数据平台那么复杂但log/*.log里的内容比控制台完整得多。启动失败先看日志能省下大量“反复启动-关闭-再启动”的无效操作。第三也是我最想说的一点启动文件只是个入口别在这里消耗太多心力。如果你发现自己已经在“Flink 怎么启动”上折腾超过半天直接切到 Docker 方案或者找一台 Linux 服务器把精力放回真正的数据开发上。Flink 新版没有 bat 不是 bug是 Windows 生态被逐步边缘化的正常结果。搞清楚背后的机制再根据环境选一条顺手的路这个问题其实五分钟就能解决。
