PyFlink-DataStream API-缺少模块

问题描述

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