????????????pip list?????????????? apache-beam 2.19.0 ????????????????????????
?????? ------------------ ???????? ------------------ ??????: "user-zh" <hxbks...@gmail.com>; ????????: 2020??10??19??(??????) ????9:53 ??????: "??????"<appleyu...@foxmail.com>; ????: "user-zh"<user-zh@flink.apache.org>; ????: Re: ????pyflink??udf??????????python3.5?????? Hi, pyflink 1.11??????python??????3.5, 3.6??3.7??????????????????????????????????apache-beam????????????????????????????beam????????????2.19 Best, Xingbo ?????? <appleyu...@foxmail.com> ??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?????????????????? >