Остановите работу, а не пытайтесь повторить определенные исключения в Apache Flink

Question

Я использую стратегию перезапуска по умолчанию для своих заданий, и она отлично работает в случае проблем, которые могут быть решены через некоторое время (нет сети, недостаточно памяти, Kafka недоступен и т. Д.). Однако, Есть некоторые исключения, которые обычно означают ошибку в коде (например, NullPointerException или любую другую необработанную), и в таких случаях я не хочу применять какую-либо стратегию перезапуска, так как любое количество перезапусков не решит проблему.

Можно ли в таких случаях остановить работу изнутри, несмотря на настроенную стратегию?

Answer 1

Я думаю, что Flink в настоящее время не поддерживает то, что вы пытаетесь достичь. Но одно из возможных решений - это перевернуть это.

1. Установите стратегию перезапуска на no retry.
2. поймать исключение, которое, по вашему мнению, будет разрешено через некоторое время (например, сообщение сети), и повторить попытку на месте
3. для других случаев отказа, бросить, чтобы остановить работу