PyFlink - DataStream API - 缺少模块
PyFlink - DataStream API - Missing module
我正在尝试从 DataStream API 开始，但缺少一个模块。
知道哪里出了问题吗？
版本
Python 3.7.9
python -m pip install apache-flink
代码
from pyflink.common.serialization import SimpleStringEncoder
错误
ModuleNotFoundError: No module named pyflink.common.serialization
PyFlink 尚不支持 DataStream API。这是为 Flink 1.12 计划的，初始工作在 FLIP-130.
中描述
如果您被文档的主版本误导了，我们深表歉意。如果您仍想尝试 Python DataStream API，您可以 build PyFlink from source.
我正在尝试从 DataStream API 开始，但缺少一个模块。
知道哪里出了问题吗？
版本
Python 3.7.9
python -m pip install apache-flink
代码
from pyflink.common.serialization import SimpleStringEncoder
错误
ModuleNotFoundError: No module named pyflink.common.serialization
PyFlink 尚不支持 DataStream API。这是为 Flink 1.12 计划的，初始工作在 FLIP-130.
中描述如果您被文档的主版本误导了，我们深表歉意。如果您仍想尝试 Python DataStream API，您可以 build PyFlink from source.