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 <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. >
