Apache Flink 1.15.2 源码目录查看

本文涉及的产品
实时计算 Flink 版,5000CU*H 3个月
简介: Apache Flink 1.15.2 源码目录查看

打开下载列表页面 https://flink.apache.org/downloads.html#apache-flink-1152
点击下载链接进入 Apache Flink 1.15.2 源码下载地址页面
https://www.apache.org/dyn/closer.lua/flink/flink-1.15.2/flink-1.15.2-src.tgz
2022-09-25-16-13-15.png
页面上查找下载地址
https://dlcdn.apache.org/flink/flink-1.15.2/flink-1.15.2-src.tgz

linux 环境下使用 tar zxf flink-1.15.2-src.tgz 命令解压,
windows 环境下可以使用7-zip解压

flink-1.15.2-src.tgz 大小大概30M,解压后大概190M
查看目录和文件
2022-09-25-16-17-06.png

根目录下有pom.xml文件,这是java开发的依赖和编译管理文件,使用IDEA打开根目录

各个目录查看说明

目录 说明
docs/ 文档说明
flink-annotations/ 注解类
flink-architecture-tests/ 体系测试
flink-clients/ 客户程序
flink-connectors/ hbase, hive, kafka等连接器 2022-09-25-16-33-29.png
flink-container/ 集群配置
flink-contrib/ Wikipedia调用
flink-core/ 核心类 2022-09-25-16-36-04.png
flink-dist/ 脚本配置等发布资源
flink-dist-scala/ Scala许可信息
flink-docs/ flink文档生成配置
flink-dstl/ 文件系统变化处理
flink-end-to-end-tests/ flink点到点测试 2022-09-25-16-39-46.png
flink-examples/ flink示例
flink-external-resources/ GPU驱动脚本
flink-filesystems/ 使用hadoop,oss等
flink-formats/ compress,csv,json等格式处理
flink-fs-tests/ 文件处理测试用例
flink-java/ java环境类处理
flink-jepsen/ Clojure项目,用来查找bug
flink-kubernetes/ kubernetes调用
flink-libraries/ 主要库
flink-metrics/ 统计处理,统计项
flink-optimizer/ 优化
flink-python/ pyflink库
flink-queryable-state/ 状态保存
flink-quickstart/ 快速开始
flink-rpc/ rpc服务端接口
flink-runtime/ 运行时
flink-runtime-web/ web运行时
flink-scala/ scala代码
flink-state-backends/ 状态保存后端
flink-streaming-java/ java流式处理
flink-streaming-scala/ scala流式处理
flink-table/ 表格类数据处理
flink-tests/ 测试用例
flink-test-utils-parent/ 测试工具类
flink-walkthroughs/ 数据流处理
flink-yarn/ yarn处理
flink-yarn-tests/ yarn测试
licenses/ 许可信息
tools/ 脚本配置等工具
相关实践学习
基于Hologres轻松玩转一站式实时仓库
本场景介绍如何利用阿里云MaxCompute、实时计算Flink和交互式分析服务Hologres开发离线、实时数据融合分析的数据大屏应用。
Linux入门到精通
本套课程是从入门开始的Linux学习课程,适合初学者阅读。由浅入深案例丰富,通俗易懂。主要涉及基础的系统操作以及工作中常用的各种服务软件的应用、部署和优化。即使是零基础的学员,只要能够坚持把所有章节都学完,也一定会受益匪浅。
目录
相关文章
|
2天前
|
消息中间件 分布式计算 Kafka
深度分析:Apache Flink及其在大数据处理中的应用
Apache Flink是低延迟、高吞吐量的流处理框架,以其状态管理和事件时间处理能力脱颖而出。与Apache Spark Streaming相比,Flink在实时性上更强,但Spark生态系统更丰富。Apache Storm在低延迟上有优势,而Kafka Streams适合轻量级流处理。选型考虑延迟、状态管理、生态系统和运维成本。Flink适用于实时数据分析、复杂事件处理等场景,使用时注意资源配置、状态管理和窗口操作的优化。
|
10天前
|
消息中间件 Oracle 关系型数据库
实时计算 Flink版操作报错合集之连接RabbitMQ时遇到Could not find any factory for identifier 'rabbitmq' that implements 'org.apache.flink.table.factories.DynamicTableFactory'错误,该怎么办
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
305 0
|
10天前
|
Kubernetes Oracle 关系型数据库
实时计算 Flink版操作报错合集之用dinky在k8s上提交作业,会报错:Caused by: org.apache.flink.table.api.ValidationException:,是什么原因
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
102 0
|
10天前
|
消息中间件 Java Kafka
实时计算 Flink版操作报错合集之从hudi读数据,报错NoSuchMethodError:org.apache.hudi.format.cow.vector.reader.PaequetColumnarRowSplit.getRecord(),该怎么办
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
11天前
|
Oracle 关系型数据库 Shell
实时计算 Flink版操作报错合集之遇到报错:Error: Could not find or load main class org.apache.flink.cdc.cli.CliFrontend,是什么导致的
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
15天前
|
监控 大数据 Java
使用Apache Flink进行大数据实时流处理
Apache Flink是开源流处理框架,擅长低延迟、高吞吐量实时数据流处理。本文深入解析Flink的核心概念、架构(包括客户端、作业管理器、任务管理器和数据源/接收器)和事件时间、窗口、状态管理等特性。通过实战代码展示Flink在词频统计中的应用,讨论其实战挑战与优化。Flink作为大数据处理的关键组件,将持续影响实时处理领域。
112 5
|
1月前
|
消息中间件 Java Kafka
实时计算 Flink版操作报错之Apache Flink中的SplitFetcher线程在读取数据时遇到了未预期的情况,该怎么解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
28天前
|
数据处理 Apache 流计算
|
1月前
|
消息中间件 关系型数据库 MySQL
Apache Flink CDC 3.1.0 发布公告
Apache Flink 社区很高兴地宣布发布 Flink CDC 3.1.0!
583 1
Apache Flink CDC 3.1.0 发布公告
|
16天前
|
数据采集 关系型数据库 MySQL
使用Apache Flink实现MySQL数据读取和写入的完整指南
使用Apache Flink实现MySQL数据读取和写入的完整指南
114 0
使用Apache Flink实现MySQL数据读取和写入的完整指南

推荐镜像

更多