# flink-runtime-1.19-learn

**Repository Path**: bluedream_pp/flink-runtime-1.19-learn

## Basic Information

- **Project Name**: flink-runtime-1.19-learn
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2024-07-07
- **Last Updated**: 2025-06-11

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

## 目的

git clone 下来的源码，因为各种原因不能编译成功。所以将 runtime 模块单独拿出来，编译运行。通过 debug 的方式，观察 TaskManager 和 JobManager
的运行时特性。

## 配置

运行需要的配置：
1. maven 最好使用 ideal 自带的版本，如果版本不匹配，可能会有兼容问题，出现各种问题
2. Java8+
3. scala 2.12.7

## 启动步骤

下载 flink-1.19.1 的安装包。国内的下载地址为；https://mirrors.tuna.tsinghua.edu.cn/apache/flink/flink-1.19.1/

使用 standalone 的模式启动 JobManager。入口程序为 StandaloneSessionClusterEntrypoint 入口即可，但是需要在 ideal 的 run configuration
中配置 Program Arguments 为 -c w_config , 加入 classpath ，使用 modify classpath , 加入路径为 ${project.dir}/w_lib ，这样就可以使用 
flink-dist 这些 jar 包了。者也是 flink-runtime 模块可以正常启动的保证。

另外一个入口类是 TaskManagerRunner , 配置的方式和 StandaloneSessionClusterEntrypoint 一样。