小编Tza*_*tev的帖子

如何在Flink作业执行期间记录未捕获的异常

我正在尝试将Sentry附加到我们的Flink集群以跟踪作业执行。Sentry充当记录器,可捕获消息并将其发送到中央服务器。默认情况下,它将捕获所有WARN或更高级别的消息。

为了使Sentry能够捕获所有问题,每当操作员引发未捕获的异常时,我都需要编写WARN或ERROR日志消息。如果重新启动策略失败,则execute()执行环境中的方法将引发最终异常,我可以适当地记录该异常。但是我还没有找到记录导致作业重新启动的异常的方法。Flink将它们记录为INFO消息,但这使它们很难从其余消息中进行过滤。

在Flink作业中处理未捕获的异常的适当方法是什么?

logging sentry apache-flink

7
推荐指数
1
解决办法
264
查看次数

Purescript中的变异状态

我刚刚开始学习Purescript所以我希望这不是一个愚蠢的问题.

假设我们有一个对象

a = {x:1,y:2}
Run Code Online (Sandbox Code Playgroud)

我们想要将x改为等于2.据我所知,如果我们使用ST monad,我们将不得不复制整个对象以更改值.如果初始对象很大,这将是非常低效的.改变对象的正确方法是什么?

purescript

4
推荐指数
1
解决办法
389
查看次数

标签 统计

apache-flink ×1

logging ×1

purescript ×1

sentry ×1