Exploring the thread mode in PyFlink
Source :
flink.apache.org
Author :
Xingbo Huang & Dian Fu
PyFlink was introduced in Flink 1.9 which purpose is to bring the power of Flink to Python users and allow Python users to develop Flink jobs in Python language. The functionality becomes more and more mature through the development in the past releases.