Glad your issue was resolved.
> 2022年3月31日 上午12:45,Jin Yi <j...@promoted.ai> 写道:
>
> i ended up debugging this down to a command execution timeout for the lettuce
> (redis client) code rather than a connection timeout. we're actually able to
> hit the redis server and port, but something wonky is going on w/ the redis
> request (command) and reply loop which is meant to be synchronous.
>
> thanks for trying to help, 胡伟华.
>
> On Tue, Mar 29, 2022 at 7:45 AM 胡伟华 <huweihua....@gmail.com
> <mailto:huweihua....@gmail.com>> wrote:
> 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 <mailto: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.
>>
>