[
https://issues.apache.org/jira/browse/FLINK-14767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16974968#comment-16974968
]
vinoyang commented on FLINK-14767:
----------------------------------
[~chesnay] When tracked the last usage, I found it was only used in
{{TaskManager.scala#runTaskManager}} method in Flink 1.8.2 codebase.
The prior code snippet is:
{code:java}
if (configuration.getBoolean(TaskManagerOptions.EXIT_ON_FATAL_AKKA_ERROR)) {
val quarantineHandler = new DefaultQuarantineHandler(
Time.milliseconds(AkkaUtils.getTimeout(configuration).toMillis),
RUNTIME_FAILURE_RETURN_CODE,
LOG.logger)
LOG.debug("Starting TaskManager quarantine monitor")
taskManagerSystem.actorOf(
Props(classOf[QuarantineMonitor], quarantineHandler, LOG.logger)
)
}
{code}
{{TaskManager.scala}} was removed in FLINK-12155.
FYI.
> Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation
> ----------------------------------------------------------------------------
>
> Key: FLINK-14767
> URL: https://issues.apache.org/jira/browse/FLINK-14767
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Configuration
> Reporter: vinoyang
> Assignee: vinoyang
> Priority: Major
>
> Since {{TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR}} has no longer been
> used. IMO, we can remove this config option.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
