- Apache Flink 文档
- 概念
- 数据流编程模型
- 分布式运行时环境
- 教程
- API 教程
- DataStream API 教程
- Setup 教程
- 本地安装教程
- 在 Windows 上运行 Flink
- 例子
- 批处理示例
- 应用开发
- 项目构建设置
- Java 项目模板
- Scala 的项目模板
- 配置依赖关系,连接器,库
- 基础 API 概念
- Scala API 扩展
- Java Lambda 表达式
- Flink DataStream API 编程指南
- 活动时间
- 事件时间/处理时间/摄取时间
- 活动时间和水印
- 状态与容错
- 算子
- DataStream 转换
- 物理分区
- 任务链和资源组
- 流连接器
- 旁路输出
- Python 编程指南(流)Beta
- 测试
- 实验特点
- Flink DataSet API 编程指南
- 数据集转换
- 容错
- 在数据集中压缩数据元
- 迭代
- Python 编程指南 Beta
- 连接器
- Hadoop 兼容性测试版
- 本地执行
- 群集执行
- Table API 和 SQL
- 概念和通用 API
- 流处理概念
- 连接到外部系统
- Table API
- SQL
- 内置函数
- 用户定义的源和接收器
- 用户定义的函数
- SQL 客户端测试版
- 数据类型和序列化
- 为 Flink 程序注册自定义序列化程序
- 管理执行
- 执行配置
- 程序打包和分布式执行
- 并行执行
- 执行计划
- 重启策略
- 类库
- FlinkCEP - Flink 的复杂事件处理
- 风暴兼容性 Beta
- 项目配置
- 执行 Storm 拓扑
- 在 Flink 流程序中嵌入 Storm 算子
- Flink Extensions
- Storm 兼容性示例
- Gelly:Flink Graph API
- 图 API
- FlinkML - Flink 的机器学习
- 最佳实践
- API 迁移指南
- 部署和运营
- 集群和部署
- 独立群集
- YARN 设置
- Mesos 设置
- Kubernetes 设置
- Docker 设置
- 亚马逊网络服务(AWS)
- Google Compute Engine 设置
- 先决条件
- 在 Google Compute Engine 上部署 Flink
- MapR 设置
- Hadoop 集成
- JobManager 高可用性(HA)
- 状态和容错
- 检查点
- 保存点
- 状态后台
- 调整检查点和大状态
- 配置
- 生产准备清单
- 命令行界面
- Scala REPL
- Kerberos 身份验证设置和配置
- SSL 设置
- 文件系统
- 升级应用程序和 Flink 版本
- 调试和监控
- 度量
- 如何使用日志记录
- 历史服务器
- 监控检查点
- 监测背压
- 监控 REST API
- 调试 Windows 和事件时间
- 调试类加载
- 应用程序分析
- 使用 Java Flight Recorder 进行性能分析
- 使用 JITWatch 进行分析
- Flink Development
- 将 Flink 导入 IDE
- 从 Source 建立 Flink
- 内幕
- 组件堆栈
- 数据流容错
- 工作和调度
- 任务生命周期
- 文件系统
- 实现
- 坚持保证
- 更新文件内容
- 覆盖文件
- 线程安全
文章来源于网络收集而来,版权归原创者所有,如有侵权请及时联系!
在 Windows 上运行 Flink
如果要在 Windows 计算机上本地运行 Flink,则需要 下载 并解压缩二进制 Flink 分发。之后,您可以使用 Windows 批处理 文件( .bat
),或使用 Cygwin 运行 Flink JobManager。
从 Windows 批处理文件开始
要从 Windows 命令行 启动 Flink ,请打开命令窗口,导航到 bin/
Flink 目录并运行 start-cluster.bat
。
注意: bin
Java Runtime Environment 的文件夹必须包含在 Window 的 %PATH%
变量中。按照本 指南 将 Java 添加到 %PATH%
变量中。
$ cd flink
$ cd bin
$ start-cluster.bat
Starting a local cluster with one JobManager process and one TaskManager process.
You can terminate the processes via CTRL-C in the spawned shell windows.
Web interface by default on http://localhost:8081/.
之后,您需要打开第二个终端来运行作业 flink.bat
。
从 Cygwin 和 Unix Scripts 开始
使用 Cygwin, 您需要启动 Cygwin 终端,导航到您的 Flink 目录并运行 start-cluster.sh
脚本:
$ cd flink
$ bin/start-cluster.sh
Starting cluster.
从 Git 安装 Flink
如果您正在从 git 存储库安装 Flink 并且您正在使用 Windows git shell,则 Cygwin 可能会产生类似于以下的故障:
c:/flink/bin/start-cluster.sh: line 30: /figure>\r': command not found
发生此错误是因为在 Windows 中运行时,git 会自动将 UNIX 行结尾转换为 Windows 样式行结尾。问题是 Cygwin 只能处理 UNIX 样式的行结尾。解决方案是通过以下三个步骤调整 Cygwin 设置以处理正确的行结尾:
- 启动一个 Cygwin shell。
- 输入确定您的主目录
cd; pwd
This will return a path under the Cygwin root path.
- 使用 NotePad,写字板或其他文本编辑器打开
.bash_profile
主目录中的文件并附加以下内容:(如果文件不存在,则必须创建它)
export SHELLOPTS
set -o igncr
保存文件并打开一个新的 bash shell。
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论