Updated on 2024-08-10 GMT+08:00

PyFlink Sample Program Development Roadmap

Assume that you need to submit a Flink task to an MRS cluster. The main language used by the service platform is Python. The following content uses an example Python program to read and writ Kafka jobs.

This scenario applies to MRS 3.3.0 or later.