我尝试从 PyFlink 和 Kafka 开始,但出现以下错误。
感谢您的支持 !
安装
python -m pip install apache-flink
pip install pyFlink
Run Code Online (Sandbox Code Playgroud)
代码
from pyFlink.datastream import StreamExecutionEnvironment
Run Code Online (Sandbox Code Playgroud)
错误
ModuleNotFoundError: No module named 'pyFlink'
Run Code Online (Sandbox Code Playgroud)