PyFlink导入错误咨询：无法从pyflink.common模块中导入Encoder类

我来帮你搞定这个导入失败的问题，这个错误核心原因是PyFlink不同版本间API的包路径发生了变化，Encoder类已经不在pyflink.common模块下了，下面分两种常见场景给你解决方案：

场景1：使用PyFlink 1.14及以上版本（推荐） #

在较新的PyFlink版本中，官方已经简化了文件写入的API，大部分场景下你根本不需要显式导入Encoder类：

• 如果你之前是在write_as_text方法中使用Encoder指定编码，直接改用encoding参数即可：
  旧代码：

  from pyflink.common import Encoder
  ds.write_as_text(output_path, encoder=Encoder(charset='UTF-8'))
  

  新代码：

  ds.write_as_text(output_path, encoding='UTF-8')
  

• 如果需要指定输出数据类型，直接使用Types模块即可：

  from pyflink.common import Types
  ds.write_as_text(output_path, output_type=Types.STRING())
  

场景2：确实需要导入Encoder类（比如兼容旧代码或自定义连接器） #

如果你的业务场景必须用到Encoder类，在PyFlink 1.14+版本中，它被移动到了pyflink.datastream.connectors.file_system模块下，修改导入语句即可：

from pyflink.datastream.connectors.file_system import Encoder

额外检查步骤 #

1. 先确认你的PyFlink版本，执行命令查看：

   pip show pyflink
   

2. 尽量参考对应版本的官方文档编写代码，PyFlink的API迭代较快，过时的示例代码很容易引发这类问题。

内容的提问来源于stack exchange，提问作者yunrui li