基于上一篇flink文章，没写完，也是倒腾了挺长时间才出来单词统计的效果。
首先，要完成一个例子 ：提交一个简单的 WordCount 作业 在docker容器中。
步骤①、：首先在宿主机中，创建input文件，并copy到jobManager容器中：
步骤②：在jobManager容器中，执行单词统计的命令：
查看：在taskManager容器中，查看output.txt文件：
死磕flink（八）
2024-09-25
53
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《
阿里云开发者社区用户服务协议》和
《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写
侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
简介：
死磕flink（八）
相关文章
|
4月前
|
消息中间件
存储
分布式计算
|
8月前
|
消息中间件
API
数据处理
Flink常见面试问题(附答案)
Apache Flink是开源的流批处理框架，提供低延迟、高吞吐的数据处理。与Hadoop不同，Flink专注于实时数据流。其核心特性包括事件时间和处理时间的概念，事件时间通过水印处理乱序事件。Flink通过检查点实现容错，支持滚动、滑动和会话窗口进行流数据处理。状态后端用于管理应用程序状态，水印用于处理延迟数据。Flink与Kafka集成能保证事件顺序，支持多种连接器如Kafka、JDBC等。其处理延迟数据、乱序事件的能力，以及Exactly-Once语义，使其在大规模数据处理中具有优势。Flink还支持表格API和DataStream API，以及多种容错和性能优化策略。
310
2
3
|
SQL
消息中间件
分布式计算
Flink 面试指南 | 终于要跟大家见面了，我有点紧张。（附思维导图）
面试，一个令人大多数同学头疼的问题，要么成功进入心仪公司，要么沮丧与其失之交臂。但是，如果能在面试前就能知道面试官将会问的问题，然后可以好好提前准备，这种感觉是不是特别棒？
17986
0
2
|
4月前
|
资源调度
流计算
Docker
|
4月前
|
消息中间件
存储
算法
|
4月前
|
消息中间件
Kafka
调度
|
4月前
|
SQL
资源调度
Kubernetes
|
4月前
|
消息中间件
存储
API
|
4月前
|
SQL
算法
API
|
4月前
|
分布式计算
大数据
数据处理
热门文章
最新文章
1
为什么说流处理即未来？
2
【实战】锐捷AC+AP配置WLAN基本服务系列
3
丰富、连接、待集成—MaxCompute 生态再出发
4
securecrt克隆会话与sshd 的 MaxSessions
5
阿里云云端即时渲染技术带您“云考古”
6
Console-算法[for]-输出等腰三角形
7
asp.net日期显示 问题
8
MFC单文档应用程序显示图像
9
最新10款精美的免费PSD网站模板下载
10
嵌入式系统工程师的十个不要
1
《docker基础篇：5.本地镜像发布到阿里云》
104
2
《人工智能可视化：数据洞察的新窗口》
38
3
《揭秘人工智能数据安全风险评估方法：守护数字未来的关键》
39
4
《探秘人工智能之关联规则挖掘：解锁数据背后的隐藏联系》
30
5
《数据质量评估方法大揭秘：精准衡量数据价值的关键》
31
6
《数据质量：人工智能模型的成败关键》
20
7
发现API安全风险，F5随时随地保障应用和API安全
17
8
机器学习在网络安全中的防护：智能化的安全屏障
28
9
基于AI的运维资源调度：效率与智能的双重提升
29
10
2024年终总结：选择错误、加班三月、降薪、面试无果...
90