Hi, pyflink 1.11支持的python版本是3.5, 3.6，3.7。这个报错看起来像是你的环境里面的apache-beam的版本太低导致的。你可以看下beam的版本是不是2.19
Best, Xingbo 大森林 <[email protected]> 于2020年10月17日周六 下午5:54写道： > > 您好！ > 请问目前的apache-flink是否必须在python3.5以下才能完全兼容？ > > 完整代码是: > > https://enjoyment.cool/2020/02/27/Three-Min-Series-How-to-create-UDF-in-PyFlink-1-10/ > > > 碰到这么个问题: > File > "dev/.conda/envs/3.5/lib/python3.5/site-packages/apache_beam/runners/common.pxd", > line 85, in init pyflink.fn_execution.fast_operations > ValueError: apache_beam.runners.common.PerWindowInvoker size changed, may > indicate binary incompatibility. Expected 160 from C header, got 152 from > PyObject > > 感觉看起来像是底层胡cython不太兼容． > 请问我是否必须使用python3.5的虚拟环境？感谢！ >
