PyFlink-数据流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，您可以从源代码构建PyFlink。