pentaho - 如何执行 X 次 Job Executor 步骤

Question

介绍

为了简单起见，让我们想象一个简单的转换。此转换从数据网格步骤获取 4 行的输入。流通过一个作业执行器，引用一个简单的作业，带有一个写入日志组件。

我希望简单的作业执行 4 次，这意味着 4 条日志消息。

事实证明，Job Executor 步骤只启动了一次简单的作业，而不是 4 次：我只有一条日志消息。

Job Executor 组件的文档指定以下内容：

默认情况下，指定的作业将为每个输入行执行一次。

这是在“行分组”选项卡中参数化的，具有以下字段：

发送到作业的行数：每 X 行之后，作业将被执行，这些 X 行将被传递给作业。

score 0 · Accepted Answer

该步骤实际上运行良好：X 行的输入将执行“作业执行器”步骤 X 次。事实是我无法通过日志看到它。

为了验证它，我在“Job Executor”步骤中添加了一个简单的转换，它写入一个文本文件。在我检查了这个文件之后，“作业执行器”似乎完美地执行了 X 次。

为了理解为什么在“作业执行器”执行 X 次后我没有 X 日志消息，我在最初的简单作业中添加了一个“等待”组件。最后，增加两秒钟让我看到执行期间出现的 X 日志消息。

希望这会有所帮助，因为它非常棘手。请随时提供更多详细信息。