使用AWS托管Apache Flink运行Python Apache Beam应用启动失败求助

求助！我最近在尝试用AWS托管的Apache Flink作为运行器跑一个简单的Python版Apache Beam应用，但刚启动就失败了，抛出了下面的异常。更头疼的是网上几乎找不到相关的避坑教程——目前能找到的大多是针对AWS托管Flink的Java版Beam应用示例，完全找不到Python相关的指导：

--------------------------- Python Process Started --------------------------  
Traceback (most recent call last):  
    File "/tmp/flink-web-5d98ef0c-f0f3-429e-ba53-60655903bff0/flink-web-upload/dac34d18-5e05-4c0c-ba49-f1b9d60dc8f9_code/main.py", line 53, in module  
        main()  
    File "/tmp/flink-web-5d98ef0c-f0f3-429e-ba53-60655903bff0/flink-web-upload/dac34d18-5e05-4c0c-ba49-f1b9d60dc8f9_code/main.py", line 36, in main  
        p  
    File "/usr/local/lib/python3.11/site-packages/apache_beam/transforms/ptransform.py", line 1110, in __ror__  
        return self.transform.__ror__(pvalueish, self.label)  
    File "..."

有没有大佬遇到过类似的问题，或者能给我一些Python版Beam适配AWS托管Flink的建议？

备注：内容来源于stack exchange，提问作者Meos