在 Cloudera Data Flow 上运行你的第一个 Flink 例子

  • 时间:
  • 浏览:2
  • 来源:大发5分6合_大发5分6合官网

图中 4 个功能模块从左到右分别解释如下:

3.在 YARN 和 Flink 的界面上分别都能看过这个任务。



2.CM 重启完成很久,加上服务页面能否 看过有 Flink 服务。

9.等待的图片 Flink History Server 启动成功,完成后点击继续。



发现 Flink 的情况汇报为灰色,CMS 有重启提示,按照提示重启 CMS 服务,重启过程略。重启完成后显示 Flink 服务正常。

1.执行 Flink 自带的 example 的 wordcount 例子。

Cloudera Data Flow(CDF) 作为 Cloudera 一个多独立的产品单元,围绕我我其实时数据派发,实时数据除理和实时数据分析有多个不同的功能模块,如下图所示:

8.点击继续。

2.查看输出结果。

5.进入 CM 主页点击“加上服务”。

1.准备 Flink 1.9 的 csd 文件,并放置到 Cloudera Manager Server 的 /opt/cloudera/csd 目录。很久重启 Cloudera Manager Server 服务。

7.选用 Flink History Server 以及 Gateway 节点,点击继续。

6.选用加上 Flink 服务,点击继续。



本文 Fayson 主很久介绍要怎样在 CDH6.3 中安装 Flink 1.9 以及运行你的第一个多 Flink 例子,以下是测试环境信息:

至此,Flink 1.9 安塞进 CDH 6.3 以及第一个多例子介绍完毕。



备注:这是 Cloudera Streaming Analytics 中所中含 Apache Flink 的抢先测试版。Cloudera 不提供对此版本的支持。该 Beta 版本的目的是让用户能否 尽机会早的结束使用 Flink 进行应用守护进程的开发。

4.通过 Hosts > Parcels 进入 Cloudera Manager 的 Parcel 页面,输入 SMM Parcel 的 http 地址,下载->分配->激活。



10.安装完成,点击完成回到 CM 主页。

3.下载 Flink 1.9 的 Parcel,并放置 /var/www/html 目录。