0

我们有一个小型集群。其中 spring xd 分布式运行时架构是 ETL 的组件。我们使用 cron 在其中安排了批处理作业。但是当作业失败或中断时，我们不会通过命名通道或电子邮件收到通知，是否可以通过向命名通道发送消息来触发批处理作业？

目前，在以下环境中运行：

Spring XD 分布式运行时 - 1.2.1

Hadoop 发行版 - PHD3.0

对此的任何帮助将不胜感激。

4

1 回答 1

0

您可能需要编写自己的步骤来为您处理通知。因此，在您的批处理流程中，您将配置一些仅在其他步骤失败时才执行的步骤。

就像是...

<job id="job">
    <step id="stepA">
        <next on="*" to="stepB" />
        <next on="FAILED" to="NotifyErrorEmail" />
    </step>
    <step id="stepB".. />
    <step id="NotifyErrorEmail" />
</job>

您可以在Spring Batch 配置步骤中阅读更多内容

于 2015-09-27T14:49:32.087 回答