History

Zheng, Qi 0b96a19526 Add flink k8s mode		2024-06-13 20:08:09 +08:00
..
kubernetes	Add flink k8s mode	2024-06-13 20:08:09 +08:00
build_occlum_instance.sh	Add flink k8s mode	2024-06-13 20:08:09 +08:00
docker-entrypoint.sh	Add flink k8s mode	2024-06-13 20:08:09 +08:00
Dockerfile	Add flink k8s mode	2024-06-13 20:08:09 +08:00
download_flink.sh	[demos] Update flink demo to version 1.15.2	2024-05-30 13:28:35 +08:00
flink.yaml	[demos] Update flink demo to version 1.15.2	2024-05-30 13:28:35 +08:00
preinstall_deps.sh	[demos] Improve steps of dependency preinstall	2023-03-29 09:31:20 +08:00
README.md	Add flink k8s mode	2024-06-13 20:08:09 +08:00
run_flink_on_occlum.sh	[demos] Update flink demo to version 1.15.2	2024-05-30 13:28:35 +08:00

README.md

Run Flink on Occlum

This is for how to run Flink job manager and task manager in Occlum. For how to start Flink K8S cluster in Occlum, please refer to kubernetes.

Preinstall dependencies

Related dependencies: openjdk-11

./preinstall_deps.sh

Download flink

./download_flink.sh

Build Occlum instance

./build_occlum_instance.sh

Run flink job manager on Occlum

./run_flink_on_occlum.sh jm

Wait a while for job manager started successfully. You can check the log occlum_instance_jobmanager/flink--standalonesession-0.log for detail status.

Run flink task manager on Occlum

Once the job manager is up, you can run the task manager.

./run_flink_on_occlum.sh tm

Wait a while for task manager started successfully. You can check the log occlum_instance_taskmanager/flink--taskmanager-0.log for detail status.

Submit a flink job to occlum

You can submit an example flink job by using the following command:

./run_flink_on_occlum.sh task

Note:
If running the jobmanager in docker, please export the port 8081 and 6123.