PyFlink-Kafka-缺少模块

问题描述

我试图从PyFlink和Kafka开始，但出现以下错误。

感谢您的支持！

安装

irb(main):013:0> [2,4,10].map {|n| factors(n)}
=> [[1,2],[1,2,4],5,10]]
irb(main):014:0> [[1,10]].inject(:&)
=> [1,2]

代码

python -m pip install apache-flink
pip install pyFlink 

错误

from pyFlink.datastream import StreamExecutionEnvironment

解决方法

要安装PyFlink，您只需执行：

python -m pip install apache-flink

并确保您具有兼容的Python版本（> = 3.5）。

导入区分大小写；因为包名称是“ pyflink”而不是“ pyFlink”，所以引发了错误。因此，您可以尝试：

from pyflink.datastream import StreamExecutionEnvironment

如果您要使用Kafka，请记住还使用以下方法添加required (JAR) dependencies：

config = t_env.get_config().get_configuration()
config.set_string("pipeline.jars","file:///path/to/jar/jarfile.jar")

您可以在PyFlink documentation中阅读有关处理连接器和其他依赖项的更多信息。