PyFlink - DataStream API - 缺少模块

Question

我正在尝试从 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

Answer 1

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

很抱歉，如果您被文档的主版本误导了。如果你还想尝试 Python DataStream API，可以build PyFlink from source。