Re: Flink启动python任务异常:undefined symbol: _Py_LegacyLocaleDetected

2022-11-21 文章 Xingbo Huang
Hi RS, 你是使用conda构建的venv吗,可以参考PyFlink 准备环境的文档[1] Best, Xingbo [1] https://pyflink.readthedocs.io/en/latest/getting_started/installation/prepare.html#create-a-virtual-environment-using-conda RS 于2022年11月22日周二 15:14写道: > Hi, > Flink版本:1.15.1 > > >

Flink启动python任务异常:undefined symbol: _Py_LegacyLocaleDetected

2022-11-21 文章 RS
Hi, Flink版本:1.15.1 A机器:在A机器上创建python虚拟环境,版本3.6.8,安装flink等python包,然后打包ZIP,jxy_venv.zip,上传到HDFS上 B机器:在B机器上,主机上没有Python环境,Flink运行在K8S的docker中,docker里面也没有python环境, C机器:在C机器上,有flink的client,存在python环境,负责启动任务 启动命令: ./bin/flink run -Dexecution.runtime-mode=BATCH -d -m 192.168.1.2:8081 -n -py

Re: 关于LocalTransportException的优化方向咨询

2022-11-21 文章 yidan zhao
hi,我们继续实验了reuse=false,max-num-tcp-connections继续为1的情况,也解决了问题。因此是reuse的问题。 yidan zhao 于2022年11月21日周一 10:34写道: > > 我们这边其实是生产环境一直有类似local/remote transport异常,其中一大类就是 Sending the partition > request to '...' failed 这种错误。 > > 当前是 1.15.2,默认 taskmanager.network.max-num-tcp-connections 是 1, >

Re: flink1.15.2无论blob.server.port设置什么端口范围,都会报错

2022-11-21 文章 yidan zhao
日志太少,建议开启debug日志后,发出来完整日志看看。 junjie.m...@goupwith.com 于2022年11月21日周一 19:04写道: > > flink1.15.2无论blob.server.port设置什么端口范围,都会报错。 > 如设置blob.server.port=“50100-50200”时报错: > Caused by: java.io.IOException: Unable to open BLOB Server in specified port > range: 50100 > at

退订

2022-11-21 文章 李朋