Are you referring to creating Flink cluster on Kubernetes by yaml file? How did you submit the job to Flink cluster? Not via the command line (flink run xxx)?
> 2022年3月29日 下午10:38，Jin Yi <j...@promoted.ai> 写道： > > no they are not. b/c we are using k8s, we use kubectl apply commands with a > yaml file to specify the startup. > > On Tue, Mar 29, 2022 at 7:37 AM 胡伟华 <huweihua....@gmail.com > <mailto:huweihua....@gmail.com>> wrote: > I see, can you provide the startup command for 1.12.3 and 1.14.4? > Are these startup commands running on the same node? > >> 2022年3月29日 下午10:32，Jin Yi <j...@promoted.ai <mailto:j...@promoted.ai>> 写道： >> >> it's running in k8s. we're not running in app mode b/c we have many jobs >> running in the same flink cluster. >> >> On Tue, Mar 29, 2022 at 4:29 AM huweihua <huweihua....@gmail.com >> <mailto:huweihua....@gmail.com>> wrote: >> Hi, Jin >> >> Can you provide more information about Flink cluster deployment modes? Is it >> running in Kubernetes/YARN or standalone mode? >> Maybe you can use application mode to keeps the environment (network >> accessibility) always keep same. Application mode will run the user-main >> method in the JobManager, >> >> [1]https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/overview/#application-mode >> >> <https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/overview/#application-mode> >> >> >> >> Jin Yi <j...@promoted.ai <mailto:j...@promoted.ai>> 于2022年3月29日周二 11:23写道： >> i have a flink job that uses redis as a sink. i optionally do some wiping >> and metadata writing from the job submitting flink program before it >> actually executes/submits the job to the job manager. when i don't do this >> redis preparation, the redis sink works completely fine. that is, the redis >> commands work fine from the taskmanager tasks. however, if i enable the >> option redis preparation from within the flink job program, it fails to >> contact redis and hits a timeout exception. >> >> previously, we were using 1.12.3, and this behavior worked fine. is the >> 1.14.4 flink docker image pretty restrictive when it comes to network access >> at the job submission client layer? >> >> thanks. >
