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> 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> 写道: > > 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> 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 <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. >>> >> >