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
>
>
>
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
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,
>
日志太少,建议开启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