You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 大森林 <ap...@foxmail.com> on 2020/10/19 03:21:39 UTC

回复： 请问pyflink的udf是否必须是python3.5谢谢！

您好！我这边pip list命令确认过了．
apache-beam&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;2.19.0
请问然后应该怎么排查呢？

谢谢您


------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <hxbks2ks@gmail.com&gt;;
发送时间:&nbsp;2020年10月19日(星期一) 上午9:53
收件人:&nbsp;"大森林"<appleyuchi@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

大森林 <appleyuchi@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;