- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我在flink 1.11.1写了一个flink batch job。作业成功完成后,我想做一些类似调用 http 服务的事情。
我添加了一个简单的作业监听器来 Hook 作业状态。问题是当 kafka 接收器运算符(operator)抛出错误时,不会触发作业监听器。我希望当我的工作失败时,它应该触发我的工作监听器并打印失败日志。
我如何确定工作是否成功完成?
我们将不胜感激。
val env = StreamExecutionEnvironment.getExecutionEnvironment
env.registerJobListener(new JobListener {
override def onJobSubmitted(jobClient: JobClient, throwable: Throwable): Unit = {
if (throwable == null) {
log.info("SUCCESS")
} else {
log.info("FAIL")
}
}
override def onJobExecuted(jobExecutionResult: JobExecutionResult, throwable: Throwable): Unit = {
if (throwable == null) {
log.info("SUCCESS")
} else {
log.info("FAIL")
}
}
})
env.createInput(input)
.filter(r => Option(r.token).getOrElse("").nonEmpty)
.addSink(kafkaProducer)
最佳答案
如果您尝试在集群上运行该作业,您可以使用您的作业 ID 在控制台中查看您的记录器消息和标准输出。请引用随附的屏幕截图,
如果您在本地集群上运行,则默认 url 可以是 http://localhost:8081。
同样,以下不是检查您的工作是否成功的正确方法。
if (throwable == null) {
log.info("SUCCESS")
} else {
log.info("FAIL")
}
关于apache-flink - Apache Flink JobListener 无法正常工作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63618060/
监听者 Listeners 是您根据调度程序中发生的事件创建的对象。 正如您可能猜到的那样,triggerlistener 接收与触发器相关的事件,而 joblistener 接收与作业相关的事件。
我正在使用 Spring 注释来连接我的应用程序依赖项。 据我所知,没有办法将我的 JobListener 注入(inject)到 Quartz SchedulerFactoryBean 中,因为它是
在我基于 Quartz.NET 的应用程序中,我有一个 JobListener,它审计所有执行到审计表的作业。但是,我也希望监听器能够在任何类型的错误发生时进行检测,这样我就可以捕获它并通过电子邮件发
我在 Java EE 应用程序的上下文中运行 Quartz 的集群实例。 Java EE 应用程序中的一个节点(随机选择)将触发一系列立即执行的 Quartz 作业(如本 post 中所述);在触发每
我在flink 1.11.1写了一个flink batch job。作业成功完成后,我想做一些类似调用 http 服务的事情。 我添加了一个简单的作业监听器来 Hook 作业状态。问题是当 kafka
我正在处理使用 Quartz 安排的服务器作业。目前我们正在尝试找到一种在作业完成时通知用户的方法。我试图使用 JobListener.jobWasExecuted() 方法,但现在似乎在作业完成执行
我刚刚将 QUARTZ 设置为与我们的企业应用程序一起使用。以下代码片段只是示例,并非取自真实的 Web 应用程序。 我的触发器/调度器类如下所示: import javax.annotation.P
JobListener的jobExecutionVetoed什么时候会在Quartz Scheduler中执行?? jobExecutionVetoed方法有什么用?? 最佳答案 假设我们有一个工作
我是 Java Batch 新手。我在 WebSphere Liberty 17.0.0.4 上部署了一个包含 JobListener 的简单批处理作业(请注意,我使用的是 IBM 的 JSR-352
我是一名优秀的程序员,十分优秀!