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

DataStream API在PyFlink中还不受支持。这是为Flink 1.12计划的，最初的工作在翻转-130中描述。

如果您被文档的主版本误导了，很抱歉。如果您仍然想尝试Python，可以使用DataStream。