Got it

where can i get brief intorduction about the restart strategy for Flink?

Created: Jun 30, 2019 15:13:42Latest reply: Jun 30, 2019 15:15:17 422 1 0 0 0
  Rewarded HiCoins: 0 (problem resolved)

where can i get brief intorduction about the restart strategy for Flink?

Featured Answers
Hi there!

The flink restart strategy

Flink supports different restart strategies that control how to restart after a job fails. The cluster can be restarted by the default restart policy. This default restart policy is usually used when no restart policy is specified. If the restart policy is specified when the job is submitted, the restart policy will override the default restart policy of the cluster.

Overview

The default restart policy is specified by Flink's flink-conf.yaml. This configuration parameter restart-strategy defines which policy will be used. If the checkpoint is not started, the no restart policy will be adopted. 

If the checkpoint mechanism is started but the restart policy is not specified, the fixed-delay policy will be used and the Integer.MAX_VALUE will be retried. Please refer to the available restart strategy below to see which values ​​are supported.

Each restart strategy has its own parameters to control its behavior. These values ​​can also be set in the configuration file. Each restart policy description contains its own configuration value information.
View more
  • x
  • convention:

All Answers
Hi there!

The flink restart strategy

Flink supports different restart strategies that control how to restart after a job fails. The cluster can be restarted by the default restart policy. This default restart policy is usually used when no restart policy is specified. If the restart policy is specified when the job is submitted, the restart policy will override the default restart policy of the cluster.

Overview

The default restart policy is specified by Flink's flink-conf.yaml. This configuration parameter restart-strategy defines which policy will be used. If the checkpoint is not started, the no restart policy will be adopted. 

If the checkpoint mechanism is started but the restart policy is not specified, the fixed-delay policy will be used and the Integer.MAX_VALUE will be retried. Please refer to the available restart strategy below to see which values ​​are supported.

Each restart strategy has its own parameters to control its behavior. These values ​​can also be set in the configuration file. Each restart policy description contains its own configuration value information.
View more
  • x
  • convention:

Comment

You need to log in to comment to the post Login | Register
Comment

Notice: To protect the legitimate rights and interests of you, the community, and third parties, do not release content that may bring legal risks to all parties, including but are not limited to the following:
  • Politically sensitive content
  • Content concerning pornography, gambling, and drug abuse
  • Content that may disclose or infringe upon others ' commercial secrets, intellectual properties, including trade marks, copyrights, and patents, and personal privacy
Do not share your account and password with others. All operations performed using your account will be regarded as your own actions and all consequences arising therefrom will be borne by you. For details, see " User Agreement."

My Followers

Login and enjoy all the member benefits

Login

Block
Are you sure to block this user?
Users on your blacklist cannot comment on your post,cannot mention you, cannot send you private messages.
Reminder
Please bind your phone number to obtain invitation bonus.