1、准备工作

到 https://archive.cloudera.com/csa/1.0.0.0/下载相应的csd文件和parcels文件到本地

FLINK-1.9.0-csa1.0.0.0-cdh6.3.0-el7.parcel

FLINK-1.9.0-csa1.0.0.0-cdh6.3.0-el7.parcel.sha

manifest.json(可以直接替换,也可以先将原来的移走)

将上面三个放到/opt/cloudera/parcel-repo目录下

FLINK-1.9.0-csa1.0.0.0-cdh6.3.0.jar 放到/opt/cloudera/csd目录下

2、重启cm server

systemctl restart cloudera-scm-server

确认重启ok,需要等待一会时间（可以查看启动日志是否ok，默认日志路径/var/log/cloudera-scm-server/cloudera-scm-server.log）

3、分配激活flink

主机->parcel  分配，激活

如果没有出现可能 需要修改一下上传的包的用户名和用户组

4、添加flink服务

5、选择主机

6、后面默认重启即可

7、测试Flink案例

创建一个word.txt文件上传到hadoop上，路径自己选择

执行

flink run -m yarn-cluster -yn 4 -yjm 1024 -ytm 1024 /opt/cloudera/parcels/FLINK/lib/flink/examples/streaming/WordCount.jar --input hdfs://bigdata-37-205:8020/tmp/flinktest/word.txt --output hdfs://bigdata-37-205:8020/tmp/result

运行成功

8、测试报错

如果执行flink的测试案例报错如图，以为我将word.txtx上传到的他/tmp路径下，而/tmp的写全权限只有hdfs,所以可以使用hdfs用户执行，或者修改一下读写权限

 

# flink # cloudera
Logo
魔乐社区

魔乐社区（Modelers.cn) 是一个中立、公益的人工智能社区，提供人工智能工具、模型、数据的托管、展示与应用协同服务，为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作，由全产业链共同建设、共同运营、共同享有，推动国产AI生态繁荣发展。

更多推荐

cover

全家桶集齐！Qwen3.5四款小模型上线魔乐社区，附昇腾全套实践教程

avatar 魔乐社区

Pont - 搭建前后端之桥：高效、灵活的接口管理工具

Pont 是一款强大的数据服务层解决方案，它能够帮助开发者快速搭建前后端之间的桥梁，实现接口的高效管理和代码自动生成。无论是新手还是有经验的开发者，都能通过 Pont 轻松处理接口文档、生成类型安全的 API 代码，从而显著提升开发效率。[![Pont 工具标志](https://raw.gitcode.com/gh_mirrors/po/pont/raw/3f1b7d4bbba3fd2dda

avatar 魔乐社区

如何快速上手 hvac：HashiCorp Vault Python 客户端零基础入门指南

**hvac** 是 HashiCorp Vault 的 Python 3.X 客户端库，专为开发者提供简单高效的 Vault 交互方式。无论你是需要管理密钥、配置身份验证，还是实现安全的秘密数据存储，hvac 都能帮助你轻松搞定 Vault 的各项操作。本文将带你零基础快速入门，从安装到基础操作，让你在几分钟内即可上手使用这个强大的工具。[![hvac 客户端 Logo](https://r

avatar 魔乐社区