一、Flink版本表
Flink作为应用广泛的实时流处理引擎，每个版本都不断地进行优化和更新。Flink版本表中记录了所有Flink的历史版本及其发布日期、状态，用户可以通过官方网站查看。在版本表中，对Flink版本的状态分为三种，分别为：Experimental、Stable、Maintenance。
Experimental：实验版本，有一些新功能或实验性质的变化，一些API接口可能发生变化。
Stable：稳定版本，在经历一段试用期后，已被大多数用户采纳，该版本的API接口不会再发生变化，而且在该版本上会修复很多bug。
Maintenance：维护版本，在该版本上不会引入新的特性，主要是修复已知的bug和安全问题。
二、Flink启动命令
在Flink的安装目录下bin目录中，可以看到启动脚本，即flink run。使用flink run可以启动一个Flink作业。例如，启动一个jobmanager：
./bin/start-cluster.shFlink还提供了web页面，可以通过web页面对Flink集群进行监控和管理。启动该web页面可以使用如下命令：
./bin/start-web.sh三、Flink版本1.13
Flink 1.13是一个很有趣的版本，它新增了很多新的功能。
1、Statful Functions：这是一种全新的应用程序编写模式，可以使流处理应用程序更灵活，更易于开发维护。
2、Python Table API和SQL：Flink 1.13的Table API和SQL支持Python，用户可以使用Python API和SQL执行流处理任务。
3、扩展Apache Kafka Connector：新版本扩展了Flink的Kafka连接器，使其支持新的kafka版本，包括Kafka 2.8/2.7/2.6/2.5/2.4/2.3/2.2。
4、增强的流式聚合：Flink 1.13增强了流式聚合的功能，users可以在聚合时使用更丰富的表达式。
四、Flink版本查看
查询Flink版本有两种方法：
1、通过log查看版本号：
> tail -f log/flink-*-standalonesession-*.log
Flink Version: 1.10.02、通过Flink Web UI查看版本号。
五、Flink版本升级
单击此处以查看Flink版本升级的详细过程。
1.备份并停止集群：在执行升级之前，需要先停止Flink集群并备份数据了，以防止数据丢失。一旦备份完成，停止flink集群。
2.更新Flink文件：现在可以将新的Flink文件复制到所有节点中去。
3.重启所有节点：
./bin/stop-cluster.sh
./bin/start-cluster.sh4.检查所有节点日志以确认是否成功。
tail -500f log/flink-*-standalonesession-*.log | grep "version"六、Flink版本差异
1.Flink 1.9：它引入了Flink-ELib，可以用于应用程序的通用数据访问（读/写），可以使用各种数据源和存储模式。
2.Flink 1.10：将基于Akka交换站重新实现为基于Netty的交换站。新的交换站提供更好的吞吐量、更好的延迟，并减少了Flink自身的内存占用。
3.Flink 1.11：引入了针对批处理优化的功能，允许Flink为事务级别的批处理任务生成两阶段提交协议。
4.Flink 1.12：针对Flink SQL和Table API的Python支持，允许使用Python API和SQL来开发和编写Flink作业。
七、启动Flink集群
1.启动Flink集群：
./bin/start-cluster.sh2.查看集群：
./bin/flink list -m localhost:80813.打开Flink Web UI：
在浏览器中输入http://localhost:8081，即可打开Flink Web UI界面。
八、Apache Flink
Apache Flink是一个开源的流处理框架，可以用于流式处理和批处理。Flink基于Java平台，可以以类似于MapReduce的编程方式来处理数据。Flink使用了一种基于流模型的编程范式，它可以对无限的数据流进行高效的处理。
目前，Flink已经是最受欢迎的流处理引擎之一，被多个行业广泛应用，例如金融、电商、物流等领域。它的优点是处理速度非常快，可以在流式处理中处理大量的数据。
原创文章，作者：小蓝，如若转载，请注明出处：https://www.506064.com/n/186729.html
微信扫一扫 
支付宝扫一扫 