Search code examples
apache-flinkpyflink

PyFlink - DataStream API - Missing module

I'm trying to start with the DataStream API, but have a missing module.

Any idea what's wrong ?

Version

Python 3.7.9

python -m pip install apache-flink

Code

from pyflink.common.serialization import SimpleStringEncoder

Error

ModuleNotFoundError: No module named pyflink.common.serialization
Solution

  • The DataStream API is not supported yet in PyFlink. This is planned for Flink 1.12, with the initial work described in FLIP-130.

    Sorry if you were misled by the master version of the documentation. If you still want to try the Python DataStream API, you can build PyFlink from source.