Can't kill a job which contains a while loop in the main method before it be submitted

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Can't kill a job which contains a while loop in the main method before it be submitted

XiangWei Huang
Hi,
I met a problem when use jedis in flink.When using jedis to get a connection to redis  if the redis server is not available then jedis will keep trying and
never end,the problem is that the job’s status is not set to RUNNING by flink, that means it can’t be killed by flink.The only way to break this look is to
restart jobmanager.
Is there another way to solve this without restart jobmanager.
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Can't kill a job which contains a while loop in the main method before it be submitted

Aljoscha Krettek
Hi,

Could you post a short snipped so that we see how your code works. If the call to jedis is in the main() method before executing Flink then the problem is actually out of Flink’s power.

Best,
Aljoscha

> On 14. Jun 2017, at 06:09, XiangWei Huang <[hidden email]> wrote:
>
> Hi,
> I met a problem when use jedis in flink.When using jedis to get a connection to redis  if the redis server is not available then jedis will keep trying and
> never end,the problem is that the job’s status is not set to RUNNING by flink, that means it can’t be killed by flink.The only way to break this look is to
> restart jobmanager.
> Is there another way to solve this without restart jobmanager.

Loading...