Вопросы Теги

Flink: следует ли перезапустить весь кластер в случае сбоя одного диспетчера задач?

Вы можете увидеть структуру объекта, возвращенного функцией summary(), вызвав str(summary(fit)). Доступ к каждой части осуществляется с помощью $. Значение p для статистики F легче получить от объекта, возвращаемого anova.

Вкратце, вы можете сделать это: 

rSquared <- summary(fit)$r.squared
pVal <- anova(fit)$'Pr(>F)'[1]
0
задан Harshith Bolar 18 January 2019 в 09:51
поделиться

1 ответ

Извините, если мой ответ в другом месте был неясен, но то, что вы делаете, хорошо. Возможно, было бы точнее сказать, что задание «сбрасывается», что происходит автоматически. Поскольку контрольные точки глобально согласованы, важно, чтобы все менеджеры задач перематывали и перезапускали обработку с состояния, записанного в контрольной точке, но Flink позаботится об этом за вас (как только необходимые ресурсы снова станут доступны).

0
ответ дан David Anderson 18 January 2019 в 09:51
поделиться