?????? ????pyflink??udf??????????python3.5??????

[??????]

????????????pip list??????????????
apache-beam                  
 2.19.0
????????????????????????

??????


------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<hxbks...@gmail.com&gt;;
????????:&nbsp;2020??10??19??(??????) ????9:53
??????:&nbsp;"??????"<appleyu...@foxmail.com&gt;;
????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;
????:&nbsp;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&gt; ??2020??10??17?????? ????5:54??????

&gt;
&gt; ??????
&gt; ??????????apache-flink??????????python3.5??????????????????
&gt;
&gt; ??????????:
&gt;
&gt; 
https://enjoyment.cool/2020/02/27/Three-Min-Series-How-to-create-UDF-in-PyFlink-1-10/
&gt;
&gt;
&gt; ??????????????:
&gt;&nbsp;&nbsp; File
&gt; 
"dev/.conda/envs/3.5/lib/python3.5/site-packages/apache_beam/runners/common.pxd",
&gt; line 85, in init pyflink.fn_execution.fast_operations
&gt; ValueError: apache_beam.runners.common.PerWindowInvoker size changed, may
&gt; indicate binary incompatibility. Expected 160 from C header, got 152 from
&gt; PyObject
&gt;
&gt; ????????????????????cython??????????
&gt; ??????????????????python3.5??????????????????
&gt;