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

Sun, 18 Oct 2020 23:40:05 -0700 

????!
Xubuntu Desktop 20.04
????pip install apache-flink
anaconda python3.6.10




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2020??10??19??(??????) ????2:06
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: ????pyflink??udf??????????python3.5??????



Hi,
1. ????????????????????mac????????????????linux
2. ??????????????????????????Pip install apache-flink??????
3. ??????conda????????Python????????????????venv????????Python????????

Best,
Xingbo

?????? <[email protected]&gt; ??2020??10??19?????? ????11:23??????

&gt; ????????3.6??anaconda??????????
&gt;
&gt;
&gt;
&gt;
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????:
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 "user-zh"
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 <
&gt; [email protected]&amp;gt;;
&gt; ????????:&amp;nbsp;2020??10??19??(??????) ????9:53
&gt; ??????:&amp;nbsp;"??????"<[email protected]&amp;gt;;
&gt; ????:&amp;nbsp;"user-zh"<[email protected]&amp;gt;;
&gt; ????:&amp;nbsp;Re: ????pyflink??udf??????????python3.5??????
&gt;
&gt;
&gt;
&gt; Hi,
&gt;
&gt; pyflink 1.11??????python??????3.5,
&gt; 
3.6??3.7??????????????????????????????????apache-beam????????????????????????????beam????????????2.19
&gt;
&gt; Best,
&gt; Xingbo
&gt;
&gt; ?????? <[email protected]&amp;gt; ??2020??10??17?????? ????5:54??????
&gt;
&gt; &amp;gt;
&gt; &amp;gt; ??????
&gt; &amp;gt; ??????????apache-flink??????????python3.5??????????????????
&gt; &amp;gt;
&gt; &amp;gt; ??????????:
&gt; &amp;gt;
&gt; &amp;gt;
&gt; 
https://enjoyment.cool/2020/02/27/Three-Min-Series-How-to-create-UDF-in-PyFlink-1-10/
&gt; &amp;gt
&gt; 
<https://enjoyment.cool/2020/02/27/Three-Min-Series-How-to-create-UDF-in-PyFlink-1-10/&amp;gt&gt;
&gt; ;
&gt; &amp;gt;
&gt; &amp;gt; ??????????????:
&gt; &amp;gt;&amp;nbsp;&amp;nbsp; File
&gt; &amp;gt;
&gt; 
"dev/.conda/envs/3.5/lib/python3.5/site-packages/apache_beam/runners/common.pxd",
&gt; &amp;gt; line 85, in init pyflink.fn_execution.fast_operations
&gt; &amp;gt; ValueError: apache_beam.runners.common.PerWindowInvoker size 
changed,
&gt; may
&gt; &amp;gt; indicate binary incompatibility. Expected 160 from C header, got 
152
&gt; from
&gt; &amp;gt; PyObject
&gt; &amp;gt;
&gt; &amp;gt; ????????????????????cython??????????
&gt; &amp;gt; ??????????????????python3.5??????????????????
&gt; &amp;gt;

回复