apache-flink - PyFlink - DataStream API - 缺少模块

Question

我正在尝试从 DataStream API 开始，但缺少一个模块。

知道有什么问题吗？

版本

蟒蛇 3.7.9

python -m pip install apache-flink

代码

from pyflink.common.serialization import SimpleStringEncoder

错误

ModuleNotFoundError: No module named pyflink.common.serialization

Answer 1

PyFlink 尚不支持 DataStream API。这是为 Flink 1.12 计划的，初始工作在FLIP-130中描述。

抱歉，如果您被文档的主版本误导了。如果您仍想尝试 Python DataStream API，您可以从 source 构建 PyFlink。