这个问题应该有人问过，你搜搜看。
另外，如果GC频繁的话，把内存调大看看～
> 在 2021年2月8日，下午5:14，陈康 <844256...@qq.com> 写道：
>
> 感谢回复...切换了版本...运行报错如下图 。。
> [hadoop@hadoop01 bin]$ pip list | grep flink
> apache-flink 1.11.1
>
> Caused by: java.util.concurrent.TimeoutException: Heartbeat of TaskManager
> with id
感谢回复...切换了版本...运行报错如下图 。。
[hadoop@hadoop01 bin]$ pip list | grep flink
apache-flink 1.11.1
Caused by: java.util.concurrent.TimeoutException: Heartbeat of TaskManager
with id 397c590a9c19b173a83a4476f8eeaca0 timed out.
... 26 more
看起来似乎是因为Flink集群的版本和PyFlink的版本不一致导致的：集群装的Flink是1.11.1，PyFlink是1.12.0？
先把版本都统一一下，再试试。
> 在 2021年2月8日，上午10:28，陈康 <844256...@qq.com> 写道：
>
> 请教大佬们： 一个最简单pyflink UDF跑起来，报 Failed to create stage bundle factory!
> INFO:root:Initializing python harness: 在IdeaIJ上可以运行、大家有遇到过吗？谢谢~
>
>
请教大佬们： 一个最简单pyflink UDF跑起来，报 Failed to create stage bundle factory!
INFO:root:Initializing python harness: 在IdeaIJ上可以运行、大家有遇到过吗？谢谢~
/opt/module/flink-1.11.1/bin/flink run -m localhost:8081 -pyexec
/opt/python36/bin/python3 -py udf.py
[hadoop@hadoop01 pyflink]$ /opt/python36/bin/python3 -V
