当前位置: 首页 > 知识库问答 >
问题:

Mulesoft批量崩溃

管玉堂
2023-03-14

我是新来mulesoft的,有一个关于批次处理的问题processing.if批次处理过程在已经处理的一些记录之间崩溃了,当批次处理作业重新开始时发生了什么。重复数据???

共有2个答案

汪安宁
2023-03-14

它将尝试继续处理批处理队列中的挂起数据,除非它被崩溃损坏。

郎建章
2023-03-14

答案取决于几件事。首先,除非将批处理作业范围配置为允许记录级失败,否则当记录失败时,整个作业将停止。其次,如果您将配置为允许失败,则批处理将继续处理所有记录。在这种情况下,可以将每个批处理步骤配置为仅接受成功记录(默认)、失败记录或所有记录。

因此,问题的答案取决于配置。

至于重复数据,这部分完全取决于您。

如果作业因失败而停止,则在重新启动作业时,此时提供的记录集将被处理。如果您提交以前处理过一次的记录,则将再次处理这些记录。您可以在重新进入批处理作业时或在成功处理记录时提供筛选。

 类似资料:
  • 在TIBCO中有全局变量的概念,在Mulesoft中有相同的概念吗? 类似于设置全局变量,以便在运行时或基于环境的部署期间。穆勒索夫有类似的案例吗

  • 问题内容: 这是我在阅读有关jpa批量插入的几个主题之后创建的简单示例,我有2个持久对象User和Site。一个用户可以拥有多个站点,因此我们在这里有一对多的关系。假设我要创建用户并将多个站点创建/链接到用户帐户。考虑到我愿意为Site对象使用批量插入,代码如下所示。 但是,当我运行此代码时(我将hibernate方式用作jpa实现提供程序),我看到以下sql输出: 所以,我的意思是“真实的”批量

  • 在Cassandra中,用于同时执行多个修改语句(插入,更新,删除)。 当你必须更新一些以及删除一些现有的列是非常有用的。 语法 实例: 让我们举个例子来演示命令。 在这里,我们有一个名为“”的表,其中包含列(,,),具有以下数据。 在这个例子中,我们将执行BATCH(插入,更新和删除)操作: 插入一个包含以下信息的新行(,,)。 更新行ID为的学生的列的值为。 删除具有行ID为的雇员的值。 完整

  • 我有一个XML,我想在Dataweave中检查是否有

  • 我试图构建一个使用安全属性配置的Mulesoft应用程序。我创建了一个settings.unencrypted.yaml文件,如下所示: 单击“测试连接”时,出现以下错误: 当我在安全属性配置中硬编码密钥时,一切正常。为什么我不能访问传入的变量作为密钥?

  • 我想问一下关于Elasticsearch批量API的问题 这是我使用批量API的代码 我遇到了超时异常,因为我的记录有800K。java.net.SocketTimeoutException:连接超时30,000毫秒http-outgoing-16[活动] 我试图分解传入的jsonList,但有时会出现相同的错误。 我目前使用的是Elasticsearch 7.6.2版本。 异常跟踪 Java.n