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

  • 时间:
  • 浏览:0
  • 来源:UU直播快三_UU直播快3平台



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



2.CM 重启完成如果 ,换成服务页面还并能 看了有 Flink 服务。

8.点击继续。

3.在 YARN 和 Flink 的界面上分别都能看了這個任务。



9.等待歌曲 Flink History Server 启动成功,完成后点击继续。

5.进入 CM 主页点击“换成服务”。

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



至此,Flink 1.9 安里装 CDH 6.3 以及第有有一一两个 例子介绍完毕。

备注:这是 Cloudera Streaming Analytics 中所含高 Apache Flink 的抢先测试版。Cloudera 不提供对此版本的支持。该 Beta 版本的目的是让用户还并能 尽由于早的现在如果刚开始使用 Flink 进行应用多多多线程 的开发。

本文 Fayson 主只是 介绍如保在 CDH6.3 中安装 Flink 1.9 以及运行你的第有有一一两个 Flink 例子,以下是测试环境信息:

Cloudera Data Flow(CDF) 作为 Cloudera 有有一一两个 独立的产品单元,围绕着实时数据收集,实时数据正确处理和实时数据分析有多个不同的功能模块,如下图所示:

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

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

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

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

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

2.查看输出结果。

6.选择换成 Flink 服务,点击继续。

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