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 <[email protected]> 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 > > > > Jin Yi <[email protected]> 于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. >> >
