pyflink1.15.3 windows 开发环境与 1.13.3 有何区别吗？
pyflink1.15.3 windows 开发环境与 1.13.3 有何区别吗？相同的代码在1.13.3 可以跑起来，在1.15.3版本就不行 Caused by: java.lang.RuntimeException: Failed to create stage bundle factory! INFO:root:Initializing Python harness: E:\pyflink\cook_predict\venv\lib\site-packages\pyflink\fn_execution\beam\beam_boot.py --id=2-1 --provision_endpoint=localhost:55846 INFO:root:Starting up Python harness in loopback mode. Caused by: org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.UncheckedExecutionException: java.lang.IllegalStateException: Process died with exit code 0 at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2050) at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache.get(LocalCache.java:3952) at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:3974) at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4958) at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4964) at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$SimpleStageBundleFactory.(DefaultJobBundleFactory.java:451) at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$SimpleStageBundleFactory.(DefaultJobBundleFactory.java:436) at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.forStage(DefaultJobBundleFactory.java:303) at org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner.createStageBundleFactory(BeamPythonFunctionRunner.java:569) ... 14 more 这是部分报错信息
写回答
-
北京阿里云ACE会长可能是 PyFlink 1.15.3 和 1.13.3 在 Windows 开发环境上有一些区别。具体来说，可能涉及到 PyFlink 1.15.3 在 Windows 上使用的 Python 版本不同，或者是 PyFlink 1.15.3和 1.13.3 之间的一些依赖关系不同。可以尝试检查 Windows 开发环境的配置是否正确，以及确保 PyFlink 1.15.3 和 Python 版本是否正确安装。
2023-07-11 22:40:44赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
